(timeout: float)
| 350 | original_wait = manager._wait_for_new_work_or_timeout |
| 351 | |
| 352 | async def signaling_wait(timeout: float) -> None: |
| 353 | wait_entered.set() |
| 354 | await original_wait(timeout) |
| 355 | |
| 356 | manager._wait_for_new_work_or_timeout = signaling_wait # ty: ignore[invalid-assignment] |
| 357 |