From 34973b8413ad0ee524afcb8151213357a4629fb8 Mon Sep 17 00:00:00 2001
From: Jake Barnby <jakeb994@gmail.com>
Date: Fri, 26 Jan 2024 00:35:37 +1300
Subject: [PATCH] Directly delete message schedule instead of deferring to
 worker

---
 src/Appwrite/Platform/Tasks/ScheduleMessages.php | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git a/src/Appwrite/Platform/Tasks/ScheduleMessages.php b/src/Appwrite/Platform/Tasks/ScheduleMessages.php
index fef0c79bb2..cc641b434a 100644
--- a/src/Appwrite/Platform/Tasks/ScheduleMessages.php
+++ b/src/Appwrite/Platform/Tasks/ScheduleMessages.php
@@ -48,23 +48,17 @@ class ScheduleMessages extends ScheduleBase
                 $queue = $pools->get('queue')->pop();
                 $connection = $queue->getResource();
                 $queueForMessaging = new Messaging($connection);
-                $queueForDeletes = new Delete($connection);
 
                 $queueForMessaging
                     ->setMessageId($schedule['resourceId'])
                     ->setProject($schedule['project'])
                     ->trigger();
 
-                $dbForConsole->updateDocument(
+                $dbForConsole->deleteDocument(
                     'schedules',
                     $schedule['$id'],
-                    new Document(['active' => false])
                 );
 
-                $queueForDeletes
-                    ->setType(DELETE_TYPE_SCHEDULES)
-                    ->trigger();
-
                 $queue->reclaim();
 
                 unset($this->schedules[$schedule['resourceId']]);