Replace this task with one which raises ExpectedException.
(self, *args)
| 371 | |
| 372 | @shared_task(bind=True) |
| 373 | def fail_replaced(self, *args): |
| 374 | """Replace this task with one which raises ExpectedException.""" |
| 375 | raise self.replace(fail.si(*args)) |
| 376 | |
| 377 | |
| 378 | @shared_task(bind=True) |