Ошибка перехвата в группе сельдерея вместо отдельной задачи

#python #django #celery #django-celery

#python #django #сельдерей #django-сельдерей

Вопрос:

Возможна ли обработка ошибок в группе сельдерея? вместо того, чтобы использовать дескриптор ошибки для задачи по отдельности? Я попробовал on_error метод. Но когда моя задача добавлена в group , как я могу обработать конкретную ошибку элемента группы?

Я пытался использовать chord , но при возникновении ошибки обратный вызов chord вызываться не будет. Итак, как я могу справиться с этой ошибкой?

Комментарии:

1. Первое, что приходит на ум, — создать цепочку с вашей группой и задачей, которая будет просматривать результаты группы и выполнять соответствующие действия…

2. @DejanLekic о, даже в цепочке есть один член? Нравится chain(grouped_tasks.si()).on_error(log_error.s())