Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Coroutine sleep

Browse Source
This commit is contained in:
Jake Barnby
2025-04-30 13:05:31 +12:00
parent 43fb92ca83
commit ea38a7f869
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Appwrite/Platform/Tasks/ScheduleFunctions.php
+2 -4
View File
@@ -72,7 +72,7 @@ class ScheduleFunctions extends ScheduleBase
foreach ($delayedExecutions as $delay => $scheduleKeys) {
\go(function () use ($delay, $scheduleKeys, $pools, $dbForPlatform) {
\sleep($delay); // in seconds
\Co::sleep($delay); // in seconds
foreach ($scheduleKeys as $scheduleKey) {
// Ensure schedule was not deleted
@@ -84,9 +84,7 @@ class ScheduleFunctions extends ScheduleBase
$this->updateProjectAccess($schedule['project'], $dbForPlatform);
$publisher = new BrokerPool($pools->get('publisher'));
$queueForFunctions = new Func($publisher);
$queueForFunctions = new Func($this->publisher);
$queueForFunctions
->setType('schedule')