()
| 648 | ) |
| 649 | |
| 650 | def timeout_callback() -> None: |
| 651 | if not result.done(): |
| 652 | result.set_exception(TimeoutError("Timeout")) |
| 653 | # In case the wrapped future goes on to fail, log it. |
| 654 | future_add_done_callback(future_converted, error_callback) |
| 655 | |
| 656 | timeout_handle = io_loop.add_timeout(timeout, timeout_callback) |
| 657 | if isinstance(future_converted, Future): |
nothing calls this directly
no test coverage detected