(self, *args, link_msg=None)
| 138 | |
| 139 | @shared_task(bind=True) |
| 140 | def replace_with_chain_which_raises(self, *args, link_msg=None): |
| 141 | c = chain(identity.s(*args), raise_error.s()) |
| 142 | link_sig = redis_echo.s() |
| 143 | if link_msg is not None: |
| 144 | link_sig.args = (link_msg,) |
| 145 | link_sig.set(immutable=True) |
| 146 | c.link_error(link_sig) |
| 147 | |
| 148 | return self.replace(c) |
| 149 | |
| 150 | |
| 151 | @shared_task(bind=True) |
nothing calls this directly
no test coverage detected