У меня есть удар Сельдерея, определенный как:
@periodic_task(run_every=(crontab(minute='*/15')), name='threshold_monitor', ignore_result=True, queue='default', options={'queue': 'default'})
def threshold_monitor():
#Threshold check login
Сельдерей проходит через супервизора как:
celery -A ProjectName beat --loglevel=info
Задача хорошо выполняется каждые 15 минут, но не удаляется изочередь сельдерея, как и ожидалось. Число продолжает расти в RabbitMq. Это ожидаемое поведение? Если нет, то как мне это исправить.
Другие настройки сельдерея:
CELERY_RESULT_BACKEND = 'rpc'
CELERY_ACKS_LATE = True
CELERY_IGNORE_RESULT = True
CELERY_TASK_IGNORE_RESULT = True
CELERYD_PREFETCH_MULTIPLIER = 1
CELERY_TASK_DEFAULT_QUEUE = 'default'
CELERY_TASK_ALWAYS_EAGER = False
CELERYD_TASK_TIME_LIMIT = 60
Скриншоты очереди RabbitMQ: обратите внимание, что элементы очереди по умолчанию выполняются и освобождаются, но сельдерей продолжает расти.
