сельдерей и как отправить задачу

Question

Я посылающий задание как ниже .....

from celery import Celery 
celery = Celery() 
celery.send_task('order_celery.order_worker', (order,)) 

От работника log..this что я получаю ....

Traceback (most recent call last): 
    File "/usr/local/lib/python2.7/dist-packages/celery-3.1.7-py2.7.egg/celery/worker/consumer.py", line 445, in on_task_received 
    strategies[name](message, body, 
KeyError: 'order_celery.order_worker' 

вот мой рабочий order_celery.py

from celery import Celery 
app = Celery('tasks', broker='redis://%s:6379/0'%redis_host,backend='redis://%s:6379/0'%redis_host) 

@app.task 
def order_worker(order): 
    return True 

Почему сельдерей не работает?

Answer 1

order_celery.py должны быть в вашем PYTHONPATH, вы должны запустить рабочий в как this:

celery -A order_worker worker --loglevel=info