А у тебя базу данных именно сам Celery юзает, или таски?

К реббиту он вроде как умеет переподключаться если он отвалился.

>А у тебя базу данных именно сам Celery юзает, или таски?

таски

А эта ошибка разве не должа убить вокер насмерть, после чего его перезапустит мастер-процесс? Или может можно это как-то настроить или реализовать самому?

Если ты можешь как-то написать код, который сделает реконект в джанге, то можешь попробовать запилить свой базовый класс таски, который будет перехватывать ошибку и пытаться сделать реконект, после чего либо заново запустить таску либо, что наверное лучше, прокинет ошибку и дальше уже будет работать стандартная схема обработки ошибок в тасках.
Так же можно перед запуком таски проверять что есть конект к базе и пытаться его поднять, прежде чем запустить её.

ну в теории должна

Хотя может я и ошибаюсь, и ошибка в таске не гасит воркер-процесс насмерть

похоже это баг celery

А таска в этом случае просто висит, или падает? Если висит - то сделать чтобы падала по таймауту, и логику перепостановки таски сделать.

У меня был другой немного кейс - селери таска дёргала внешний ресурс, он иногда мог 5хх возвращать, и была логика перепосылки

ну проблема не в таске. таска то не теряется. проблема в воркере - что он не перезапускается

Аа, не понял проблемы сразу)

У celery есть сигналы, можно воркер в котором сдох коннект отротировать принудительно, если в сигнале проверить почему умерла таска.

О, прикольно! Поизучаю эту тему

Основной нюанс, сигналы отрабатывают в ноде, а не в воркере. Последний раз, когда на них смотрел документация была на уровне "есть сигналы".

https://events.yoomoney.ru/play_yoomoneyday_trek1
Трнасляция конфы от яндекс деньги, если кто забыл, но хотел посмотреть

у них два трека оказывается
https://events.yoomoney.ru/play_yoomoneyday_trek2  (этот менеджерский, а не технический)

А мне ютуб вот это подсунул

https://youtu.be/brA7HLZEN4w

Они там opentelemetry продвигали, а тут емнип на него кто-то очень ругался