Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-24 09:28:40 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Directly delete message schedule instead of deferring to worker

Browse source
This commit is contained in:
Jake Barnby 2024-01-26 00:35:37 +13:00
parent e81ab1d1e0
commit 34973b8413
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
1 changed files with 1 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/Appwrite/Platform/Tasks/ScheduleMessages.php
View file

@ -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']]);