Как добавить в очередь laravel только одну задачу?

Question

[cryptodoxer]

Есть длинные задачи, от 2 до 30 минут. Нужно чтобы очередь не росла, если в воркере есть уже задача.
Что имеем.
Kernel.php

$schedule->command('source')->withoutOverlapping()->everyMinute();

Command

$count = Redis::lrange('queues:source', 0, -1);

if (count($count) == 0)
    dispatch((new \App\Jobs\Source())->onConnection('redis')->onQueue('source'));

Job для примера длинного воркера

public function handle()
{
    dump('job work');
    sleep(2000);
}

Но даже так вижу в очереди новые задачи, что висят по таймауту. То есть задача добавляется все равно, вне зависимости от условий.

Comments

[Maronus]

Я возможно не знаю всех ваших условий, но может вместо schedule просто вызывать dispatch по окончании предыдущей задачи? Выполнили предыдущую и сразу стартанули следующую такую же, без необходимости постоянно их чекать.

public function handle()
{
    dump('job work');
    sleep(2000);
    dispatch((new \App\Jobs\Source())->onConnection('redis')->onQueue('source'));
}

[cryptodoxer]

Maronus, а как гарантировано вызвать первый раз? или при фейле задачи

[Maronus]

cryptodoxer, При фейле есть специальный handler для этого.
А при вызове в первый раз - хороший вопрос. В моих проектах "инициирующее" действие идет извне, то бишь от контроллера. Если у вас должно постоянно в фоне что-то работать одно за другим, то $schedule->withoutOverlapping() - как раз то, что нужно. Возможно проблема в "ручной" проверке количества элементов очереди.
Если в command больше ничего не делается, то попробуйте так:

$schedule->job(\App\Jobs\Source::class, 'source')->withoutOverlapping()->everyMinute();

[cryptodoxer]

Maronus, это было бы отлично! если бы Job не выполнялся долго. Потому вызывается команда, которая кладет Job в очередь.

[Maronus]

cryptodoxer,
У меня взлетел такой вариант:

$schedule
            ->call(function () {
                if (Queue::size('test_queue') == 0)
                    dispatch(new TestJob())->onQueue('test_queue');
            })
            ->everyMinute();

Хоть каждую секунду вызывай schedule:run - в очереди не больше одной задачи.

[cryptodoxer]

Maronus, у меня очередь в редисе и horizon, ща проверю - спасибо

[Maronus]

cryptodoxer,
Так у меня тоже redis, просто в конфиге прописано) А Queue как раз дает абстракцию от конкретного сервиса очередей. Отпишись если ок, то продублирую ответом.

[cryptodoxer]

Maronus, вроде бы все ок)) спасибо!

[cryptodoxer]

Maronus, и подскажи плиз - как правильно теперь подставить таймауты для именной очереди, я не знаю сколько она точно будет выполняться - ну не больше скажем 60 минут точно. Писать максимум?

[Maronus]

cryptodoxer, таймаут выставляется либо в параметре воркера, либо в самом классе job-а. В доке подробнее.
В первом случае укажи --queue=source для конкретной очереди, а во втором - ты определяешь таймаут для конкретной задачи, не важно в какой она очереди.

А по времени - да, предполагаемый максимум. Только обрати внимание, что выставляется значение в секундах, а не в минутах.

Answer 1

[Maronus]

$schedule
            ->call(function () {
                if (Queue::size('source') == 0)
                    dispatch(new Source())->onQueue('source');
            })
            ->everyMinute();