CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-10-01 01:37:56 +13:00
Code Issues Projects Releases Wiki Activity

Fix function schedules

Browse source
This commit is contained in:
Jake Barnby 2024-01-11 19:32:24 +13:00
parent 62304f817d
commit 449e8cc06c
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/Appwrite/Platform/Tasks/ScheduleFunctions.php
View file

@ -23,7 +23,7 @@ class ScheduleFunctions extends ScheduleBase
public static function getSupportedResource(): string
{
return 'message';
return 'function';
}
protected function enqueueResources(Group $pools, Database $dbForConsole): void
@ -73,11 +73,11 @@ class ScheduleFunctions extends ScheduleBase
foreach ($scheduleKeys as $scheduleKey) {
// Ensure schedule was not deleted
if (!isset($schedules[$scheduleKey])) {
if (!\array_key_exists($scheduleKey, $this->schedules)) {
return;
}
$schedule = $schedules[$scheduleKey];
$schedule = $this->schedules[$scheduleKey];
$queueForFunctions = new Func($connection);
@ -95,7 +95,10 @@ class ScheduleFunctions extends ScheduleBase
}
$timerEnd = \microtime(true);
$this->lastEnqueueUpdate = $timerStart;
// TODO: This was a bug before because it wasn't passed by reference, enabling it breaks scheduling
//$this->lastEnqueueUpdate = $timerStart;
Console::log("Enqueue tick: {$total} executions were enqueued in " . ($timerEnd - $timerStart) . " seconds");
}
}