Function _wait_for_condition

python/e2e/test_client_lifecycle_e2e.py:25–32

(predicate, timeout: float = 10.0)

async def _wait_for_condition(predicate, timeout: float = 10.0) -> None:
    deadline = asyncio.get_running_loop().time() + timeout
    while True:
        if predicate():
            return
        if asyncio.get_running_loop().time() >= deadline:
            raise TimeoutError("condition was not met before timeout")
        await asyncio.sleep(0.05)


async def _wait_for_last_session_id(client) -> str: