Python-сообщество

@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

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

Python-сообщество

Уведомления

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

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

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

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

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

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

Board footer