график сельдерея не работает

Question

Я использую сельдерей и пытаюсь запустить corntab. Ниже мой celery.py

from __future__ import absolute_import 
from celery.schedules import crontab 


from celery import Celery 

app = Celery('Celery_1', 
      broker='amqp://test:test@localhost//', 
      include=['Celery_1.tasks']) 

# Optional configuration, see the application user guide. 
app.conf.update(
    CELERY_TASK_RESULT_EXPIRES=3600, 
    CELERYBEAT_SCHEDULE = { 
    'T1': { 
     'task': 'Celery_1.tasks.add', 
     'schedule': crontab(minute='*/1'), 
     'args': (4, 5) 
} 
}, 
    CELERY_IMPORTS = ('Celery_1.tasks',) 

) 

if __name__ == '__main__': 
    app.start() 

И мой tasks.py

from __future__ import absolute_import 

from Celery_1.celery import app 


@app.task(name='Celery_1.add') 
def add(x, y): 
    return x + y 

когда я планировать по сельдерея бить

, но она не работает задание на каждую минуту. Кто-нибудь может мне помочь, пожалуйста ?

Answer 1

Вы должны запустить его таким образом (в то время как еще в каталоге Celery_1):

echo $null >> __init__.py #to make your directory a python project cd .. celery -A Celery_1 beat

Celery_1 это имя вашего приложения.