1
0
Fork 0
mirror of synced 2024-06-14 16:54:52 +12:00

Address comments

This commit is contained in:
Bradley Schofield 2024-01-24 17:44:29 +00:00
parent d3e9d03329
commit ab2d830cc0
4 changed files with 23 additions and 5 deletions

View file

@ -85,7 +85,7 @@ RUN chmod +x /usr/local/bin/doctor && \
chmod +x /usr/local/bin/ssl && \
chmod +x /usr/local/bin/test && \
chmod +x /usr/local/bin/vars && \
chmod +x /usr/local/bin/retry-jobs && \
chmod +x /usr/local/bin/queue-retry && \
chmod +x /usr/local/bin/worker-audits && \
chmod +x /usr/local/bin/worker-certificates && \
chmod +x /usr/local/bin/worker-databases && \

3
bin/queue-retry Normal file
View file

@ -0,0 +1,3 @@
#!/bin/sh
php /usr/src/code/app/cli.php queue-retry $@

View file

@ -1,3 +0,0 @@
#!/bin/sh
php /usr/src/code/app/cli.php retry-jobs $@

View file

@ -2,11 +2,14 @@
namespace Appwrite\Platform\Tasks;
use Appwrite\Event\Event;
use Twig\Node\Expression\Test\EvenTest;
use Utopia\CLI\Console;
use Utopia\Platform\Action;
use Utopia\Queue\Client;
use Utopia\Queue\Connection;
use Utopia\Validator\Text;
use Utopia\Validator\WhiteList;
class RetryJobs extends Action
{
@ -20,7 +23,20 @@ class RetryJobs extends Action
{
$this
->desc('Retry failed jobs from a specific queue identified by the name parameter')
->param('name', '', new Text(128), 'Queue name')
->param('name', '', new WhiteList([
Event::DATABASE_QUEUE_NAME,
Event::DELETE_QUEUE_NAME,
Event::AUDITS_QUEUE_NAME,
Event::MAILS_QUEUE_NAME,
Event::FUNCTIONS_QUEUE_NAME,
Event::USAGE_QUEUE_NAME,
Event::WEBHOOK_CLASS_NAME,
Event::CERTIFICATES_QUEUE_NAME,
Event::BUILDS_QUEUE_NAME,
Event::MESSAGING_QUEUE_NAME,
Event::MIGRATIONS_QUEUE_NAME,
Event::HAMSTER_CLASS_NAME
]), 'Queue name')
->inject('queue')
->callback(fn ($name, $queue) => $this->action($name, $queue));
}
@ -43,6 +59,8 @@ class RetryJobs extends Action
return;
}
Console::log('Retrying failed jobs...');
$queueClient->retry();
}
}