Ребят, если использовать Celery задачи в составе chain, то результат

Question

Ребят, если использовать Celery задачи в составе chain, то результат

предыдущей задачи передаётся в следующую первым аргументом. Это неплохо, когда у тебя жёстко заданная цепочка тасок, но что, если таски весьма абстрактны и цепочки генерируются по факту получения данных ? Единственный способ, передавать из таски в таску какой-то словарь-аккумулятор результатов, но тогда, получается, что каждая таска должна знать, что вынимать из этого аккумулятора, а тут, уже сами понимаете, нарушаются базовые принципы и вообще, о какой абстрактности идёт речь?
Я даже хз, а в чём вопрос-то? Сам не представляю... Похоже, не вариант на коленке ничего подобного слепить из пары задач. Нужно на каждую операцию создавать "умную" таску, которая знает особенности своего предназначения...

#backend #programming #python #russian

0

20.06.2022

4 ответов

34 просмотра

Philipp Bondarev Автор вопроса

Alex
> Это неплохо, когда у тебя жёстко заданная цепоч...

ОТОЖ! Я уже и сам к этому выводу пришёл...

0

20.06.2022

Tishka17

Alex
> Это неплохо, когда у тебя жёстко заданная цепоч...

А почему не сделать одну таску?

0

20.06.2022

Alex

Tishka17
А почему не сделать одну таску?

я про это и говорю

0

20.06.2022

Alex · Accepted Answer

> Это неплохо, когда у тебя жёстко заданная цепочка тасок, но что, если таски весьма абстрактны и цепочки генерируются по факту получения данных ? Чейн нужен для распараллеливания по-сути однотипных тасок. Или же разнотипных, но тогда без передачи аргументов. > ? Единственный способ, передавать из таски в таску какой-то словарь-аккумулятор результатов Может тогда и параллелизм не нужен? Получается что у тебя довольно жестко связанный код и возможно проще будет его одним воркером отработать.

170 похожих чатов

Ребят, если использовать Celery задачи в составе chain, то результат

4 ответов

Похожие вопросы