1
0
Fork 0
mirror of synced 2024-06-03 03:14:50 +12:00

adding limit to queue retry

This commit is contained in:
shimon 2024-02-28 21:01:42 +02:00
parent 84f47dc1d2
commit 53438accce

View file

@ -9,6 +9,7 @@ use Utopia\Queue\Client;
use Utopia\Queue\Connection;
use Utopia\Validator\Integer;
use Utopia\Validator\WhiteList;
use Utopia\Validator\Wildcard;
class QueueRetry extends Action
{
@ -36,18 +37,24 @@ class QueueRetry extends Action
Event::MIGRATIONS_QUEUE_NAME,
Event::HAMSTER_CLASS_NAME
]), 'Queue name')
->param('limit', 0, new Integer(true), 'jobs limit', true)
->param('limit', null, new Wildcard(), 'jobs limit', true)
->inject('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 mixed $limit
* @param Connection $queue
*/
public function action(string $name, int $limit, Connection $queue): void
public function action(string $name, mixed $limit, Connection $queue): void
{
if (!\is_numeric($limit) && $limit !== null) {
Console::error('$limit parameter should be an integer');
return;
}
if (!$name) {
Console::error('Missing required parameter $name');
return;