fix: fix optim issue with optimization

jina/serve/runtimes/worker/batch_queue.py

@@ -200,6 +200,7 @@ async def _assign_results(
             for docs_group, request_idx in zip(docs_grouped, completed_req_idxs):
                 request = self._requests[request_idx]
                 request_completed = self._requests_completed[request_idx]
+                request.direct_docs = None # batch queue will work in place, therefore result will need to read from data.
                 request.data.set_docs_convert_arrays(
                     docs_group, ndarray_type=self._output_array_type
                 )

jina/serve/runtimes/worker/request_handling.py

@@ -704,6 +704,7 @@ async def handle(
                     **self._batchqueue_config[exec_endpoint],
                 )
             # This is necessary because push might need to await for the queue to be emptied
+            # the batch queue will change the request in-place
             queue = await self._batchqueue_instances[exec_endpoint][param_key].push(
                 requests[0]
             )