Task that fails and is retried. Returns headers.
(self, *args, max_retries=1,
countdown=0.1)
| 256 | |
| 257 | @shared_task(bind=True, max_retries=1) |
| 258 | def retry_once_headers(self, *args, max_retries=1, |
| 259 | countdown=0.1): |
| 260 | """Task that fails and is retried. Returns headers.""" |
| 261 | if self.request.retries: |
| 262 | return self.request.headers |
| 263 | raise self.retry(countdown=countdown, |
| 264 | max_retries=max_retries) |
| 265 | |
| 266 | |
| 267 | @shared_task |