Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-22 16:38:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

adding limit to queue retry

Browse source
This commit is contained in:
shimon 2024-02-28 20:21:35 +02:00
parent 1538f78c18
commit 84f47dc1d2
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/Appwrite/Platform/Tasks/QueueRetry.php
View file

@ -7,6 +7,7 @@ use Utopia\CLI\Console;
use Utopia\Platform\Action;
use Utopia\Queue\Client;
use Utopia\Queue\Connection;
use Utopia\Validator\Integer;
use Utopia\Validator\WhiteList;
class QueueRetry extends Action
@ -35,15 +36,17 @@ class QueueRetry extends Action
Event::MIGRATIONS_QUEUE_NAME,
Event::HAMSTER_CLASS_NAME
]), 'Queue name')
->param('limit', 0, new Integer(true), 'jobs limit', true)
->inject('queue')
->callback(fn ($name, $queue) => $this->action($name, $queue));
->callback(fn ($name, $limit, $queue) => $this->action($name, $limit, $queue));
}
/**
* @param string $name The name of the queue to retry jobs from
* @param int $limit
* @param Connection $queue
*/
public function action(string $name, Connection $queue): void
public function action(string $name, int $limit, Connection $queue): void
{
if (!$name) {
Console::error('Missing required parameter $name');
@ -59,6 +62,6 @@ class QueueRetry extends Action
Console::log('Retrying failed jobs...');
$queueClient->retry();
$queueClient->retry($limit);
}
}