Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-23 08:58:35 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

chore: update schedule functions task

Browse source
This commit is contained in:
Chirag Aggarwal 2025-12-23 14:47:26 +05:30
parent 309fde38f7
commit 9ab9f6d709
1 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -19,7 +19,7 @@ class ScheduleFunctions extends ScheduleBase
public const UPDATE_TIMER = 10; // seconds
public const ENQUEUE_TIMER = 60; // seconds
private ?float $lastEnqueueUpdate = null;
protected ?float $lastEnqueueUpdate = null;
public static function getName(): string
{
@ -36,6 +36,11 @@ class ScheduleFunctions extends ScheduleBase
return RESOURCE_TYPE_FUNCTIONS;
}
protected function getQueueForFunctions(): Func
{
return new Func($this->publisherFunctions);
}
protected function enqueueResources(Database $dbForPlatform, callable $getProjectDB): void
{
$timerStart = \microtime(true);
@ -95,8 +100,7 @@ class ScheduleFunctions extends ScheduleBase
$this->updateProjectAccess($schedule['project'], $dbForPlatform);
$queueForFunctions = new Func($this->publisherFunctions);
$queueForFunctions = $this->getQueueForFunctions();
$queueForFunctions
->setType('schedule')
->setFunction($schedule['resource'])