async def METHOD_NAME(logger, port_generator):
    connection_pool = GrpcConnectionPool(runtime_name='gateway')
    executor_port = port_generator()
    executor_address = f'0.0.0.0:{executor_port}'
    executor_deployment = 'executor0'
    flow = Flow().add(name=executor_deployment, port=executor_port, uses=DummyExecutor)
    with flow:
        connection_pool.add_connection(
            deployment=executor_deployment, address=executor_address, head=False
        )
        request = DataRequest()
        request.data.docs = DocumentArray(Document())
        response, _ = await connection_pool.send_requests_once(
            requests=[request], deployment=executor_deployment
        )
        assert response.data.docs[0].text == 'dummy'