()
| 632 | ) |
| 633 | |
| 634 | def timeout_callback() -> None: |
| 635 | if not result.done(): |
| 636 | result.set_exception(TimeoutError("Timeout")) |
| 637 | # In case the wrapped future goes on to fail, log it. |
| 638 | future_add_done_callback(future_converted, error_callback) |
| 639 | |
| 640 | timeout_handle = io_loop.add_timeout(timeout, timeout_callback) |
| 641 | if isinstance(future_converted, Future): |
nothing calls this directly
no test coverage detected