Celery (worker) getting tasks with producer (Django) shutdown

I am using Celery as a worker for Django API calls. My current stack is:

  • Producer: Django app
  • Message Broker: Redis server
  • Consumer: Celery app

The issue is: If my Django app is shutdown, and I have the redis-server running, and start the worker with:

python3 -m celery -A b3 worker -l info

It starts getting tasks, which doesn't make much sense since my producer isn't producing any tasks.

Celery getting tasks

My tasks.py:

@shared_task()
def fetch_stock_task(company_code: str):
    ...
Back to Top