def METHOD_NAME():
    class MyExecutor(Executor):
        @requests
        def foo(self, **kwargs):
            return DocumentArray([Document(), Document()])
    port = random_port()
    f = Flow(port=port).add(uses=MyExecutor)
    with f:
        ret = Client(port=f.port).post(
            on='/some_endpoint',
            inputs=[Document() for _ in range(3)],
            parameters={'hello': 'world', 'topk': 10},
        )
    assert len(ret) == 2