(self, **kwargs)
| 157 | @self.app.task(bind=True, max_retries=10, iterations=0, shared=False, |
| 158 | autoretry_for=(Exception,)) |
| 159 | def retry_task_max_retries_override(self, **kwargs): |
| 160 | # Test for #6436 |
| 161 | self.iterations += 1 |
| 162 | if self.iterations == 3: |
| 163 | # I wanna force fail here cause i have enough |
| 164 | self.retry(exc=MyCustomException, max_retries=0) |
| 165 | self.retry(exc=MyCustomException) |
| 166 | |
| 167 | self.retry_task_max_retries_override = retry_task_max_retries_override |
| 168 |