(self, arg1, arg2, kwarg=1, max_retries=None, care=True)
| 78 | |
| 79 | @self.app.task(bind=True, max_retries=3, iterations=0, shared=False) |
| 80 | def retry_task(self, arg1, arg2, kwarg=1, max_retries=None, care=True): |
| 81 | self.iterations += 1 |
| 82 | rmax = self.max_retries if max_retries is None else max_retries |
| 83 | |
| 84 | assert repr(self.request) |
| 85 | retries = self.request.retries |
| 86 | if care and retries >= rmax: |
| 87 | return arg1 |
| 88 | else: |
| 89 | raise self.retry(countdown=0, max_retries=rmax) |
| 90 | |
| 91 | self.retry_task = retry_task |
| 92 |