async def METHOD_NAME(request: Request):
    query_params = dict(request.query_params)
    req = DataRequest()
    req.header.exec_endpoint = endpoint_path
    if not docarray_v2:
        from docarray import Document
        req.data.docs = DocumentArray([Document.from_dict(query_params)])
    else:
        req.document_array_cls = DocList[input_doc_model]
        req.data.docs = DocList[input_doc_model]([input_doc_model(**query_params)])
    event_generator = _gen_dict_documents(await caller(req))
    return EventSourceResponse(event_generator)