Как зарегистрировать исключение с помощью автоповтора в задачах Celery - PullRequest
Новая
       133

Как зарегистрировать исключение с помощью автоповтора в задачах Celery

0 голосов
/ 03 мая 2020

Из документации по сельдерею, 

If you want to automatically retry on any error, simply use:

@app.task(autoretry_for=(Exception,))
def x():
    ...

Как мы регистрируем исключение, к которому он повторил попытку? Было бы легко добавить журнал, если у нас есть попытка, за исключением, например, 

@app.task(bind=True, default_retry_delay=30 * 60)  # retry in 30 minutes.
def add(self, x, y):
    try:
        something_raising()
    except Exception as exc:
        logger.info('Retry for exception %s', exc)
        # overrides the default delay to retry after 1 minute
        raise self.retry(exc=exc, countdown=60)

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

...