Я следую этому руководству: http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html
Мой файл proj.celery:
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from celery.schedules import crontab
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'hc.settings')
app = Celery('hc')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()
@app.task
def debug_task(a):
print a
app.conf.beat_schedule = {
# Executes every Monday morning at 7:30 a.m.
'debug-every-minute': {
'task': 'tasks.debug_task',
'schedule': crontab(),
'args': ("BLa BLA BlA", ),
},
}
также я добавил периодическую задачу в /admin/django_celery_beat/
Я понимаю, что нет смысла использовать в админке как app.conf.beat_schedule
, так и Period_task, но я не вижу ожидающих записей после
Starting development server at http://127.0.0.1:8000/
Quit the server with CONTROL-C.
(ожидаю, что под этим будет написано бла-бла) Где я не прав?
celery -A proj worker -l info
в оболочке, вы увидите вывод там. - person trixn   schedule 01.02.2017