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

Ответы (0 шт):