Пользовательская периодическая задача Django celery не выполняется

Я попытался с помощью этого кода попытаться динамически добавить / удалить запланированные задачи.

Мой файл tasks.py выглядит так:

from celery.decorators import task
import logging
log = logging.getLogger(__name__)

@task
def mytask():
    log.debug("Executing task")
    return

Проблема в том, что задачи на самом деле не выполняются (т. е. нет вывода журнала), но я получаю следующие сообщения в файле журнала celery точно по расписанию:

[2013-05-10 04:53:00,005: INFO/MainProcess] Got task from broker:   cron.tasks.mytask[dfcf397b-e30b-45bd-9f5f-11a17a51b6c4]
[2013-05-10 04:54:00,007: INFO/MainProcess] Got task from broker: cron.tasks.mytask[f013b3cd-6a0f-4060-8bcc-3bb51ffaf092]
[2013-05-10 04:55:00,007: INFO/MainProcess] Got task from broker: cron.tasks.mytask[dfc0d563-ff4b-4132-955a-4293dd3a9ac7]
[2013-05-10 04:56:00,012: INFO/MainProcess] Got task from broker: cron.tasks.mytask[ba093535-0d70-4dc5-89e4-441b72cfb61f]

Я могу точно подтвердить, что регистратор настроен правильно и работает нормально. Если бы я попытался вызвать result = mytask.delay() в интерактивной оболочке, result.state бесконечно содержал бы состояние PENDING.

РЕДАКТИРОВАТЬ: см. также Django Celery Periodic Tasks. Выполнить, но очереди RabbitMQ не используются


python django celery djcelery
person nonocat    schedule 09.05.2013    source источник
comment
Какой сервер результатов вы используете?   -  person gatto    schedule 09.05.2013
comment
@gatto я использую amqp   -  person nonocat    schedule 09.05.2013
comment
Вместо этого я попробую использовать Redis, чтобы узнать, связано ли это с брокером сообщений.   -  person nonocat    schedule 09.05.2013
comment
Я не использовал Redis, но попытался использовать брокер сообщений django:// и серверную часть mysql, чтобы увидеть, и это работает. Я также просмотрел журналы rabbitmq и обнаружил беспорядок с постоянными внезапными отключениями. В данный момент я работаю над Windows (совсем не очень хорошая идея) и снова попробую RabbitMQ на подходящей ОС...   -  person nonocat    schedule 10.05.2013
comment
@gatto спасибо, что подтолкнул меня в правильном направлении   -  person nonocat    schedule 10.05.2013