Как определить окончание работы ряда Job задач в laravel?

Question

[Александр Михайленко]

Добрый день, у меня такая ситуация: в очередь пользователем может ставится N задача (в реале от 1 до 20), и все они подразумевают один процесс, просто очень мелко разбитый на детали.
Как правильно организовать проверку выполнения всей цепочки задачи ? или же как определить что именно последняя цепочка в задаче была выполнена и фронт может обращаться за результатом ?
Сейчас фронт просто делает запросы и проверяет поле "status" в котором указывается состояние, но у меня не всегда получается сделать так что бы последняя задача завершилась и последней, бывает так что в ходе работы скрипта возникает ошибки и данная задача возвращается снова в очередь (у каждой задачи есть 8 попыток на выполнение)

Answer 1

[Николай]

Ну а какие варианты? Фронт где-то далеко в системе клиент-сервер. Если фронт закончил запрос к серверу, то для него, что очередь там, что не очередь. Т.е. в вопросе два момента:
1. Как фронт получает обновление статуса: либо обращается к нужному ендпоинту, либо поднимает веб-сокет соединение и слушает.
2. Как бэкенд понимает, что Job готов. Насколько я помню, в Laravel есть события для этого. Дальнейшая реализация обработки событий зависит от того, как фронт "слушает" изменения - выставляешь ты флаг для ендпоинта или отправляешь событие в сокет.

Comments

[Александр Михайленко]

У меня 4 задачи, считаются одной для пользователя, а событие фиксирует выполнение каждой задачи. Насчет сокетов - могли бы вы чуть больше подсказать, не работал с ними еще

[Николай]

Александр Михайленко, честно, я не понимаю, что вы хотите. Как я понимаю, ваш фронт, после отправки запроса в очередь, начинает делать AJAX запросы на ендпоинт и анализировать ответы. Это ведь нормальный работающий механизм. Если у вас из-за этого очень много запросов AJAX и сервер испытывает сложности под запросами, то переходите на сокеты. Если нет, оставьте как есть.

Как себя должен вести фронт если выполнены 3 из 4 задач - никто не знает - это ваша бизнес логика. Если вы запускаете задачи не последовательно, то никаких последних там нет. И только вашему приложению может быть ведомо, что надо делать при выполненном наборе задач.

[Александр Михайленко]

Николай, Задача - записать в БД признак, что все N задач пользователя выполнены. Но из за того что задачи могут возвращаться в очередь, получается что последняя по счету задача выполняется не всегда последней

[Геннадий]

Александр Михайленко, это проблемы вашей архитектуры, но если переделать под очередь задач не получается, то попробуйте писать в конце выполнения каждой джобы в кеш/редис счетчиком. Насколько я помню, он там атомарный.
\Cache::increment('key');
И просто в конце каждой джобы прописать код

\Cache::increment('key');
if (\Cache::has('key') and  \Cache::get('key') >= 4)
{
$model->status = 'done';
$model->save();
}

Грубо говоря как-то так.
Если задач N можете рядом еще положить в кеш число с которым проверять, а не константное 4.