Увеличения времени сельдерея повторов каждого повтор цикл

Question

я повторные попытки с сельдереем, как в Документах-примере:

@task() 
def add(x, y): 
    try: 
     ... 
    except Exception, exc: 
     add.retry(exc=exc, countdown=60) # override the default and 
              # retry in 1 minute 

Как я могу увеличить Retry-отсчет каждый раз, когда происходит повторная попытка для этого задания - например, 60 секунд, 2 минуты, 4 минуты и так далее до тех пор, пока MaxRetriesExceeded не будет поднят?

Answer 1

Вот простой способ создать большую задержку каждый раз, когда задача оценивается. Это значение обновляется самим сельдерием, поэтому вам не нужно ничего обойти.

@task() 
def add(x, y): 
    try: 
     ... 
    except Exception as exc: 
     raise add.retry(exc=exc, countdown=60 * add.request.retries) 

Примечание: первая задача повторяется с обратным отсчетом 0. Так как число повторений равно 0 для первого запуска.

Answer 2

Держите переменный с вашим последним временем повтора в нем, и умножить его на 2 каждый раз, пока она не превышает любой уровень вы хотите (или сохранить счет, если вы предпочитаете определенное количество раз ...)

Answer 3

С version 4.2 вы можете использовать опции autoretry_for и retry_backoff для этих целей, например:

@task(max_retries=10, autoretry_for=(Exception,), retry_backoff=60) 
def add(x, y): 
    pass