Ошибка задачи сельдерея бесконечный цикл
У меня проблема с использованием сельдерея с моим приложением 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
Любой совет, как избежать ввода в этот цикл задач при возникновении ошибки
заранее спасибо