From 9e3b9b8e59265b1a12a408776f063bb4708deb68 Mon Sep 17 00:00:00 2001
From: shimon <shimon@appwrite.io>
Date: Fri, 11 Nov 2022 10:21:53 +0200
Subject: [PATCH] addressing comments

---
 app/tasks/schedule.php | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/app/tasks/schedule.php b/app/tasks/schedule.php
index d23314066e..a4ec1c5c04 100644
--- a/app/tasks/schedule.php
+++ b/app/tasks/schedule.php
@@ -55,13 +55,11 @@ $cli
         Console::success("Queue was built in " . ($loadEnd - $loadStart) . " seconds");
     };
 
-    $removeFromQueue = function ($scheduleId) use (&$queue) {
+    $removeFromQueue = function ($resourceId) use (&$queue) {
         foreach ($queue as $slot => $schedule) {
-            foreach ($schedule as $function) {
-                if ($scheduleId === $function['resourceId']) {
-                    Console::error("Unsetting :{$function['resourceId']} from queue slot $slot");
-                    unset($queue[$slot][$function['resourceId']]);
-                }
+            if (array_key_exists($resourceId, $schedule)) {
+                Console::error("Unsetting :{$resourceId} from queue slot $slot");
+                unset($queue[$slot][$resourceId]);
             }
         }
     };