Задать вопрос
@Morg4n

Как использовать локальные настройки celery в django?

Есть django приложение с кучей периодических заданий в celery, что нужно написать в local_settings, чтобы запускалось _только_ одно определенное задание.
Пробовал делать вот так, но не помогает:
BROKER_URL = 'amqp://test:test@localhost/'
CELERYBEAT_SCHEDULER = "djcelery.schedulers.DatabaseScheduler"
CELERYBEAT_SCHEDULE = {
    "test_task": {
        "task": "test.ptask",
        "schedule": crontab(minute="*/5"),
        "options": {'queue': 'slow_tasks'}
    }
}

Спасибо.
  • Вопрос задан
  • 306 просмотров
Подписаться 2 Оценить Комментировать
Решения вопроса 1
@Morg4n Автор вопроса
Правильно запускать воркера следующим образом
manage.py celery -A app_name worker -l warn -Q slow_tasks --concurrency=10
Ответ написан
Комментировать
Пригласить эксперта
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Похожие вопросы