Ошибка задачи сельдерея бесконечный цикл

У меня проблема с использованием сельдерея с моим приложением DJANGO. Когда у задачи есть ошибка, задачи входят в цикл и запускаются снова вместо завершения задачи. Моя задача запускает хранимую процедуру из базы данных. В хранимой процедуре, если есть ошибки, отправьте электронное письмо и выйти из хранимой процедуры.

У меня есть два рабочих с разным параллелизмом

celery multi start carga_w conc_w -A provcon -Q:conc_w conc -Q:carga_w carga -l info -c:conc_w 1 -c:carga_w 3 -E

задача:

@task(queue='conc')
def conci(idprov,pfecha):
    conci = Buscar_Conci()
    spconc = conci.buscarcon(idprov,pfecha)
    return None

Попытка очистить задачу не сработает, и задача - сохранить ее в памяти. Для очистки задачи я использую следующую команду:

celery -A provcon purge -f

Я впервые использую Celery с DJANGO и не знаю, пропустил ли я что-то или у меня неправильные настройки:

BROKER_URL = 'redis://localhost:6379/0'
CELERY_IMPORTS = ("pc.tasks", )
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_RESULT_BACKEND='djcelery.backends.cache:CacheBackend'

Чтобы убить задачу при входе в этот цикл, мне нужно убить ее из базы данных, потому что я не могу остановиться с сайта django-admin или с помощью команды celery purge

Любой совет, как избежать ввода в этот цикл задач при возникновении ошибки

заранее спасибо

0 ответов

Другие вопросы по тегам