(inner)
| 976 | futures.future_discard_from_awaited_by(inner, cur_task) |
| 977 | |
| 978 | def _inner_done_callback(inner): |
| 979 | if outer.cancelled(): |
| 980 | return |
| 981 | |
| 982 | if inner.cancelled(): |
| 983 | outer.cancel() |
| 984 | else: |
| 985 | exc = inner.exception() |
| 986 | if exc is not None: |
| 987 | outer.set_exception(exc) |
| 988 | else: |
| 989 | outer.set_result(inner.result()) |
| 990 | |
| 991 | def _outer_done_callback(outer): |
| 992 | if not inner.done(): |
nothing calls this directly
no test coverage detected
searching dependent graphs…