Celery (worker) получает задания при отключении producer (Django)

Я использую Celery в качестве рабочего для вызовов API Django. Мой текущий стек выглядит следующим образом:

  • Производитель: Django app
  • Брокер сообщений: Redis сервер
  • Потребитель: Celery app

Проблема заключается в следующем: Если мое приложение Django выключено, и у меня запущен redis-сервер, и я запускаю рабочий с:

python3 -m celery -A b3 worker -l info

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

Сельдерей получает задания

Мой tasks.py:

@shared_task()
def fetch_stock_task(company_code: str):
    ...
Вернуться на верх