(self, arg1, arg2, kwarg=1, max_retries=None, care=True)
| 442 | |
| 443 | @self.app.task(bind=True, max_retries=3, iterations=0, shared=False) |
| 444 | def retry_task(self, arg1, arg2, kwarg=1, max_retries=None, care=True): |
| 445 | self.iterations += 1 |
| 446 | rmax = self.max_retries if max_retries is None else max_retries |
| 447 | |
| 448 | assert repr(self.request) |
| 449 | retries = self.request.retries |
| 450 | if care and retries >= rmax: |
| 451 | return arg1 |
| 452 | else: |
| 453 | raise self.retry(countdown=0, max_retries=rmax) |
| 454 | |
| 455 | self.retry_task = retry_task |
| 456 |