Function _release

tools/loadtest.py:316–317

(t: asyncio.Task)

    in_flight: set[asyncio.Task] = set()

    def _release(t: asyncio.Task) -> None:
        in_flight.discard(t)

    while time.monotonic() < stop_at:
        now = time.monotonic()