()
| 594 | ) |
| 595 | |
| 596 | def timeout_callback() -> None: |
| 597 | if not result.done(): |
| 598 | result.set_exception(TimeoutError("Timeout")) |
| 599 | # In case the wrapped future goes on to fail, log it. |
| 600 | future_add_done_callback(future_converted, error_callback) |
| 601 | |
| 602 | timeout_handle = io_loop.add_timeout(timeout, timeout_callback) |
| 603 | if isinstance(future_converted, Future): |
nothing calls this directly
no test coverage detected