Как работает retry в Celery?

Middle
179 просмотров
AFK Offer AI

self.retry(exc=exc, countdown=60, max_retries=3) — повторить задачу через 60 секунд. autoretry_for=(ConnectionError,) — автоматический retry для указанных исключений. retry_backoff=True — экспоненциальный backoff (2, 4, 8 секунд). retry_jitter=True — случайный разброс для избежания thundering herd. retry_backoff_max=600 — максимальная задержка. Для идемпотентности: задача должна быть безопасна для повторного выполнения. Если задача не идемпотентна — используй unique task ID и проверку в начале.

Следующий вопрос

Реализуйте пул соединений к базе данных