django-celeryのretryのやり方

from celery import shared_task

@shared_task(autoretry_for=(NameError,), max_retries=3, retry_backoff=10)
def chunks_test(self, val, val2):
    # 処理

autoretry_for

リトライするエクセプションの種類です

max_retries

何回リトライするか

retry_backoff

リトライまでの待機時間で、
時間は指数関数的に増加します(2^n 秒)
file
こういうこと

コメントを残す

メールアドレスが公開されることはありません。 * が付いている欄は必須項目です