(destination)
| 392 | _set_concurrent_future_state(future, other) |
| 393 | |
| 394 | def _call_check_cancel(destination): |
| 395 | if destination.cancelled(): |
| 396 | if source_loop is None or source_loop is events._get_running_loop(): |
| 397 | source.cancel() |
| 398 | else: |
| 399 | source_loop.call_soon_threadsafe(source.cancel) |
| 400 | |
| 401 | def _call_set_state(source): |
| 402 | if (destination.cancelled() and |
nothing calls this directly
no test coverage detected
searching dependent graphs…