(self, propagate=True, callback=None)
| 360 | self.on_ready.throw(*args, **kwargs) |
| 361 | |
| 362 | def maybe_throw(self, propagate=True, callback=None): |
| 363 | cache = self._get_task_meta() if self._cache is None else self._cache |
| 364 | state, value, tb = ( |
| 365 | cache['status'], cache['result'], cache.get('traceback')) |
| 366 | if state in states.PROPAGATE_STATES and propagate: |
| 367 | self.throw(value, self._to_remote_traceback(tb)) |
| 368 | if callback is not None: |
| 369 | callback(self.id, value) |
| 370 | return value |
| 371 | maybe_reraise = maybe_throw # XXX compat alias |
| 372 | |
| 373 | def _to_remote_traceback(self, tb): |
no test coverage detected