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

injecting poolForQueue to schedulers

Browse source
This commit is contained in:
shimon 2024-10-28 12:04:58 +02:00
parent 509f06c2f0
commit 118252d3af
4 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/Appwrite/Platform/Tasks/ScheduleBase.php
View file

@ -26,7 +26,7 @@ abstract class ScheduleBase extends Action
abstract public static function getName(): string;
abstract public static function getSupportedResource(): string;
abstract public static function getCollectionId(): string;
abstract protected function enqueueResources(Pool $poolForQueue, Database $dbForConsole, callable $getProjectDB): void;
abstract protected function enqueueResources(\Utopia\Pools\Pool $poolForQueue, Database $dbForConsole, callable $getProjectDB): void;
public function __construct()
{

2
src/Appwrite/Platform/Tasks/ScheduleExecutions.php
View file

@ -28,7 +28,7 @@ class ScheduleExecutions extends ScheduleBase
return 'executions';
}
protected function enqueueResources(Pool $poolForQueue, Database $dbForConsole, callable $getProjectDB): void
protected function enqueueResources(\Utopia\Pools\Pool $poolForQueue, Database $dbForConsole, callable $getProjectDB): void
{
$queue = $poolForQueue->pop();
$connection = $queue->getResource();

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

@ -32,7 +32,7 @@ class ScheduleFunctions extends ScheduleBase
return 'functions';
}
protected function enqueueResources(Pool $poolForQueue, Database $dbForConsole, callable $getProjectDB): void
protected function enqueueResources(\Utopia\Pools\Pool $poolForQueue, Database $dbForConsole, callable $getProjectDB): void
{
$timerStart = \microtime(true);
$time = DateTime::now();

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

@ -27,7 +27,7 @@ class ScheduleMessages extends ScheduleBase
return 'messages';
}
protected function enqueueResources(Pool $poolForQueue, Database $dbForConsole, callable $getProjectDB): void
protected function enqueueResources(\Utopia\Pools\Pool $poolForQueue, Database $dbForConsole, callable $getProjectDB): void
{
foreach ($this->schedules as $schedule) {
if (!$schedule['active']) {