task.apply_async создает больше одной задачи
У меня есть две задачи в celery, задачи запускаются в зависимости от условия, проблема заключается в том что иногда при запуске задачи запускается не одна а несколько таких задач, что приводит к последующему созданию еще нескольких задач. Хотелось ы узнать в чем проблема.
if game.numbers_remaining and game.next_prizes:
progress_game.apply_async(args=(bingo_size,),
countdown=game.number_draw_delay + draw_delay)
else:
repeat_game.apply_async(args=(bingo_size,), countdown=draw_delay)
Запускаю код в контейнерах, для django и celery разные контейнеры Вот запуск воркера
command: celery -A bingo12 worker -l warning