diff --git a/jina/serve/runtimes/worker/http_csp_app.py b/jina/serve/runtimes/worker/http_csp_app.py
index 06255aaf478a5..d440941c86449 100644
--- a/jina/serve/runtimes/worker/http_csp_app.py
+++ b/jina/serve/runtimes/worker/http_csp_app.py
@@ -117,7 +117,7 @@ async def process(body) -> output_model:
             if body.parameters is not None:
                 req.parameters = body.parameters
             req.header.exec_endpoint = endpoint_path
-            req.document_array_cls = DocList[input_doc_model]
+            req.document_array_cls = DocList[input_doc_list_model]
 
             data = body.data
             if isinstance(data, list):