Как избежать дублирования выполнения задачи в сельдерее?И как назначить работника в очередь по умолчанию - PullRequest
1 голос
/ 28 мая 2019

Моя задача выполняется более одного раза за две минуты. но запланировано на один раз в celery_beat очереди.

Попытка перезапустить сельдерей с помощью команды supervisorctl как supervisorctl stop all и supervisorctl stop all

app.autodiscover_tasks(settings.INSTALLED_APPS, related_name='tasks')

app.conf.task_default_queue = 'default'
app.conf.task_routes = {'cloudtemplates.tasks.get_metrics': {'queue': 'metrics'}}

app.conf.beat_schedule = {
    'load-softlyer-machine-images': {
        'task': 'load_ibm_machine_images',
        'schedule': crontab(0, 0, day_of_month='13'),
        'args': '',
        'options': {'queue': 'celery_beat'},
    }
}

Ожидается, что запланированное задание будет выполнено только один раз 13-го числа каждого месяца.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...