DjangoBB LoFi version

Полная версия: Celery. Выполнить таск определенным воркером

Начало » Django » Celery. Выполнить таск определенным воркером

@br@c@d@br

Авг. 17, 2012 14:25:02

Всем привет!
Имеется 2 воркера и задача:

CELERYBEAT_SCHEDULE = {
    "every-day": {
        "task": "main.tasks.some_task",
        "schedule": crontab(hour=3, minute=30),
        },
    }

Сейчас эта задача, стартует, как и положено, в 3,30, но она выполняется сразу на 2х воркерах. Вопрос в следующем, как назначить выполнение этой задачи только одним определенным воркером?

Lexander

Авг. 17, 2012 16:22:53

Как то странно.
Для начала включите настройки CELERY_SEND_EVENTS и CELERY_SEND_TASK_SENT_EVENT и проанализируйте результат в celerymon.

@br@c@d@br

Авг. 17, 2012 19:40:05

Да, похоже вы правы, таск падает при выполнении на первом воркере, а затем выполняется на втором. Буду разбираться. Спасибо!