Function handler

tests/test_upstream_dual_pool.py:187–189

(headers)

        return await original_acquire(*args, **kwargs)

    async def handler(headers):
        await asyncio.sleep(MIXED_REQUEST_DELAY)
        return FakeResponse(200)

    client = UpstreamClient()
    original_acquire = guest_pool.acquire