Python Celery Multi Unregistred Task
I have two queues in Celery and one tasks.py with tasks. When I run celery with celery worker -A myapp -l info -Q messages1 celery worker -A myapp -l info -Q messages2 in two d
Solution 1:
The problem was solved with two steps:
1) Correct run string for celery multi was celery multi start 2 -Q:1 messages1 -Q:2 messages2 --loglevel=DEBUG -A myapp
2) I forgot to import my app in the __init__.py
:
`from __future__ import absolute_import
from myapp.celery_app import celery_app as celery_app`
And this link from the log message is realy useful. http://docs.celeryq.org/en/latest/userguide/tasks.html#task-names
Post a Comment for "Python Celery Multi Unregistred Task"