Task that fails and is retried. Returns the number of retries.
(self, *args, expires=None, max_retries=1, countdown=0.1)
| 236 | |
| 237 | @shared_task(bind=True, expires=120.0, max_retries=1) |
| 238 | def retry_once(self, *args, expires=None, max_retries=1, countdown=0.1): |
| 239 | """Task that fails and is retried. Returns the number of retries.""" |
| 240 | if self.request.retries: |
| 241 | return self.request.retries |
| 242 | raise self.retry(countdown=countdown, |
| 243 | expires=expires, |
| 244 | max_retries=max_retries) |
| 245 | |
| 246 | |
| 247 | @shared_task(bind=True, max_retries=1) |