diff --git a/requirements.txt b/requirements.txt
index 73dd97d..86070c9 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -1,2 +1,2 @@
-jina>=3.19.0
+jina>=3.20.0
 docarray[hnswlib]>=0.34.0
diff --git a/vectordb/db/executors/typed_executor.py b/vectordb/db/executors/typed_executor.py
index 2b224d1..66a34a8 100644
--- a/vectordb/db/executors/typed_executor.py
+++ b/vectordb/db/executors/typed_executor.py
@@ -16,7 +16,6 @@ OutputSchema = TypeVar('OutputSchema', bound='BaseDoc')
 
 methods = ['/index', '/update', '/delete', '/search']
 
-
 class TypedExecutor(Executor, Generic[InputSchema, OutputSchema]):
     # the BaseDoc that defines the schema of the store
     # for subclasses this is filled automatically
@@ -30,11 +29,23 @@ class TypedExecutor(Executor, Generic[InputSchema, OutputSchema]):
         for k, v in self._requests.items():
             if k != __dry_run_endpoint__:
                 if k != '/search':
-                    self._requests[k] = _FunctionWithSchema(self._requests[k].fn, DocList[self._input_schema],
-                                                            DocList[self._input_schema])
+                    self._requests[k] = _FunctionWithSchema(fn=self._requests[k].fn,
+                                                            is_generator=self._requests[k].is_generator,
+                                                            is_batch_docs=self._requests[k].is_batch_docs,
+                                                            is_singleton_doc=self._requests[k].is_singleton_doc,
+                                                            parameters_is_pydantic_model=self._requests[k].parameters_is_pydantic_model,
+                                                            parameters_model=self._requests[k].parameters_model,
+                                                            request_schema=DocList[self._input_schema],
+                                                            response_schema=DocList[self._input_schema])
                 else:
-                    self._requests[k] = _FunctionWithSchema(self._requests[k].fn, DocList[self._input_schema],
-                                                            DocList[self._output_schema])
+                    self._requests[k] = _FunctionWithSchema(fn=self._requests[k].fn,
+                                                            is_generator=self._requests[k].is_generator,
+                                                            is_batch_docs=self._requests[k].is_batch_docs,
+                                                            is_singleton_doc=self._requests[k].is_singleton_doc,
+                                                            parameters_is_pydantic_model=self._requests[k].parameters_is_pydantic_model,
+                                                            parameters_model=self._requests[k].parameters_model,
+                                                            request_schema=DocList[self._input_schema],
+                                                            response_schema=DocList[self._output_schema])
 
     @property
     def handle_persistence(self):