CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-06-03 11:24:48 +12:00
Code Issues Projects Releases Wiki Activity

adding limit to queue retry

Browse source
This commit is contained in:
shimon 2024-02-28 21:09:10 +02:00
parent 53438accce
commit 658396b4a8
1 changed files with 3 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -37,7 +37,7 @@ class QueueRetry extends Action
Event::MIGRATIONS_QUEUE_NAME,
Event::HAMSTER_CLASS_NAME
]), 'Queue name')
->param('limit', null, new Wildcard(), 'jobs limit', true)
->param('limit', 0, new Wildcard(), 'jobs limit', true)
->inject('queue')
->callback(fn ($name, $limit, $queue) => $this->action($name, $limit, $queue));
}
@ -50,18 +50,14 @@ class QueueRetry extends Action
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;
}
$limit = (int)$limit;
$queueClient = new Client($name, $queue);
var_dump($limit);
if ($queueClient->countFailedJobs() === 0) {
Console::error('No failed jobs found.');
return;