i had same issue where i use 2 celery containers, adding task_routes helped me resolve it on celery.py
app.conf.task_routes = { 'function_path.task.function': {'queue': 'mysite'} }