(executor_started: threading.Event, release_executor: threading.Event)
| 511 | |
| 512 | |
| 513 | def _block_executor(executor_started: threading.Event, release_executor: threading.Event) -> None: |
| 514 | executor_started.set() |
| 515 | assert release_executor.wait(timeout=5) |
| 516 | |
| 517 | |
| 518 | def _hold_read_write_lock( |
nothing calls this directly
no outgoing calls
no test coverage detected