Merge branch 'master' of https://github.com/jina-ai/jina into print-t…

…imes
jina-ai · Jul 23, 2024 · 303ee14 · 303ee14
2 parents 0970493 + 4eaeb2d
commit 303ee14
Show file tree

Hide file tree

Showing 11 changed files with 80 additions and 43 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -270,6 +270,7 @@
 
 
 
+
 
 
 # Change Logs
@@ -672,6 +673,7 @@ Jina is released on every Friday evening. The PyPi package and Docker Image will
 - [Release Note (`3.25.1`)](#release-note-3251)
 - [Release Note (`3.25.2`)](#release-note-3252)
 - [Release Note (`3.26.0`)](#release-note-3260)
+- [Release Note (`3.27.0`)](#release-note-3270)
 
 <!-- END doctoc generated TOC please keep comment here to allow auto update -->
 
@@ -16699,3 +16701,24 @@ Jina is released on every Friday evening. The PyPi package and Docker Image will
  - [[```53ec704f```](https://github.com/jina-ai/jina/commit/53ec704fb62f6b07c5e7fae1f567b412cc07c624)] __-__ __docs__: update TOC (*Jina Dev Bot*)
  - [[```faa8bd7d```](https://github.com/jina-ai/jina/commit/faa8bd7d6fa13a9af17d5f727066cc95ce5645b6)] __-__ __version__: the next version will be 3.25.3 (*Jina Dev Bot*)
 
+<a name=release-note-3-27-0></a>
+## Release Note (`3.27.0`)
+
+> Release time: 2024-07-18 17:00:58
+
+
+
+🙇 We'd like to thank all contributors for this new release! In particular,
+ Joan Martinez,  Joan Fontanals,  Jina Dev Bot,  🙇
+
+
+### 🆕 New Features
+
+ - [[```cf7284f8```](https://github.com/jina-ai/jina/commit/cf7284f8064c62c2f4e47012b63b5bf26f3d009e)] __-__ add flush all option to dynamic batching configuration (#6179) (*Joan Fontanals*)
+
+### 🍹 Other Improvements
+
+ - [[```93139c3a```](https://github.com/jina-ai/jina/commit/93139c3ae90ff33b6aec4b3d99d4360faff0c461)] __-__ upgrade ver (*Joan Martinez*)
+ - [[```e0f620dc```](https://github.com/jina-ai/jina/commit/e0f620dc6a8a74bd79b315b76dc4570d10cb82a7)] __-__ __docs__: update TOC (*Jina Dev Bot*)
+ - [[```5ccbb80e```](https://github.com/jina-ai/jina/commit/5ccbb80e4f027b60ea1ba3ae0c46ae81f9426ed9)] __-__ __version__: the next version will be 3.26.1 (*Jina Dev Bot*)
+
diff --git a/docs/_versions.json b/docs/_versions.json
@@ -1 +1 @@
-[{"version": "v3.26.0"}, {"version": "v3.25.2"}, {"version": "v3.25.1"}, {"version": "v3.25.0"}, {"version": "v3.24.1"}, {"version": "v3.24.0"}, {"version": "v3.23.5"}, {"version": "v3.23.4"}, {"version": "v3.23.3"}, {"version": "v3.23.2"}, {"version": "v3.23.1"}, {"version": "v3.23.0"}, {"version": "v3.22.4"}, {"version": "v3.22.3"}, {"version": "v3.22.2"}, {"version": "v3.22.1"}, {"version": "v3.22.0"}, {"version": "v3.21.1"}, {"version": "v3.21.0"}, {"version": "v3.20.3"}, {"version": "v3.20.2"}, {"version": "v3.20.1"}, {"version": "v3.20.0"}, {"version": "v3.19.1"}, {"version": "v3.19.0"}, {"version": "v3.18.0"}, {"version": "v3.17.0"}, {"version": "v3.16.1"}, {"version": "v3.16.0"}, {"version": "v3.15.2"}, {"version": "v3.15.0"}, {"version": "v3.14.1"}, {"version": "v3.14.0"}, {"version": "v3.13.1"}, {"version": "v3.13.0"}, {"version": "v3.12.0"}, {"version": "v3.11.0"}, {"version": "v3.10.1"}, {"version": "v3.10.0"}, {"version": "v3.9.3"}, {"version": "v3.9.2"}, {"version": "v3.9.1"}, {"version": "v3.9.0"}, {"version": "v3.8.4"}, {"version": "v3.8.0"}, {"version": "v3.7.14"}, {"version": "v3.7.0"}, {"version": "v3.6.16"}, {"version": "v3.6.1"}, {"version": "v3.6.0"}, {"version": "v3.5.0"}, {"version": "v3.4.11"}, {"version": "v3.4.0"}, {"version": "v3.3.25"}, {"version": "v3.3.0"}, {"version": "v3.2.10"}, {"version": "v3.2.0"}]
+[{"version": "v3.27.0"}, {"version": "v3.26.0"}, {"version": "v3.25.2"}, {"version": "v3.25.1"}, {"version": "v3.25.0"}, {"version": "v3.24.1"}, {"version": "v3.24.0"}, {"version": "v3.23.5"}, {"version": "v3.23.4"}, {"version": "v3.23.3"}, {"version": "v3.23.2"}, {"version": "v3.23.1"}, {"version": "v3.23.0"}, {"version": "v3.22.4"}, {"version": "v3.22.3"}, {"version": "v3.22.2"}, {"version": "v3.22.1"}, {"version": "v3.22.0"}, {"version": "v3.21.1"}, {"version": "v3.21.0"}, {"version": "v3.20.3"}, {"version": "v3.20.2"}, {"version": "v3.20.1"}, {"version": "v3.20.0"}, {"version": "v3.19.1"}, {"version": "v3.19.0"}, {"version": "v3.18.0"}, {"version": "v3.17.0"}, {"version": "v3.16.1"}, {"version": "v3.16.0"}, {"version": "v3.15.2"}, {"version": "v3.15.0"}, {"version": "v3.14.1"}, {"version": "v3.14.0"}, {"version": "v3.13.1"}, {"version": "v3.13.0"}, {"version": "v3.12.0"}, {"version": "v3.11.0"}, {"version": "v3.10.1"}, {"version": "v3.10.0"}, {"version": "v3.9.3"}, {"version": "v3.9.2"}, {"version": "v3.9.1"}, {"version": "v3.9.0"}, {"version": "v3.8.4"}, {"version": "v3.8.0"}, {"version": "v3.7.14"}, {"version": "v3.7.0"}, {"version": "v3.6.16"}, {"version": "v3.6.1"}, {"version": "v3.6.0"}, {"version": "v3.5.0"}, {"version": "v3.4.11"}, {"version": "v3.4.0"}, {"version": "v3.3.25"}, {"version": "v3.3.0"}, {"version": "v3.2.10"}, {"version": "v3.2.0"}]
diff --git a/jina/__init__.py b/jina/__init__.py
@@ -76,7 +76,7 @@ def _ignore_google_warnings():
 # do not change this line manually this is managed by git tag and updated on every release
 # NOTE: this represents the NEXT release version
 
-__version__ = '3.27.0'
+__version__ = '3.27.1'
 
 # do not change this line manually
 # this is managed by proto/build-proto.sh and updated on every execution

diff --git a/jina/clients/base/http.py b/jina/clients/base/http.py
@@ -243,9 +243,9 @@ def _result_handler(result):
                 _e2 = timeit.default_timer()
                 print(f'Create DataRequest from r_str took {_e2 - _e}s')
                 if da is not None:
-                    resp.data.docs = da
+                    resp.direct_docs = da
                 _e3 = timeit.default_timer()
-                print(f'Setting resp.data.docs took {_e3 - _e2}s')
+                print(f'Setting direct_docs took {_e3 - _e2}s')
 
                 callback_exec(
                     response=resp,

diff --git a/jina/clients/mixin.py b/jina/clients/mixin.py
@@ -419,7 +419,7 @@ async def _get_results(*args, **kwargs):
                     if return_responses:
                         result.append(resp)
                     else:
-                        result.extend(resp.data.docs)
+                        result.extend(resp.docs)
 
             _end = timeit.default_timer()
             print(f'######## {_end} => I AM GETTING RESULTS took {_end - _start}s')
@@ -446,6 +446,7 @@ async def _get_results(*args, **kwargs):
             results_in_order=results_in_order,
             stream=stream,
             prefetch=prefetch,
+            return_type=return_type,
             on=on,
             **kwargs,
         )
@@ -518,7 +519,6 @@ async def post(
         c.continue_on_error = continue_on_error
 
         parameters = _include_results_field_in_param(parameters)
-
         async for result in c._get_results(
             on=on,
             inputs=inputs,
@@ -549,7 +549,7 @@ async def post(
                     is_singleton = True
                     result.document_array_cls = DocList[return_type]
             if not return_responses:
-                ret_docs = result.data.docs
+                ret_docs = result.docs
                 if is_singleton and len(ret_docs) == 1:
                     yield ret_docs[0]
                 else:

diff --git a/jina/serve/runtimes/worker/http_fastapi_app.py b/jina/serve/runtimes/worker/http_fastapi_app.py
@@ -102,16 +102,16 @@ async def post(body: input_model, response: Response):
             data = body.data
             if isinstance(data, list):
                 if not docarray_v2:
-                    req.data.docs = DocumentArray.from_pydantic_model(data)
+                    req.direct_docs = DocumentArray.from_pydantic_model(data)
                 else:
                     req.document_array_cls = DocList[input_doc_model]
-                    req.data.docs = DocList[input_doc_list_model](data)
+                    req.direct_docs = DocList[input_doc_list_model](data)
             else:
                 if not docarray_v2:
-                    req.data.docs = DocumentArray([Document.from_pydantic_model(data)])
+                    req.direct_docs = DocumentArray([Document.from_pydantic_model(data)])
                 else:
                     req.document_array_cls = DocList[input_doc_model]
-                    req.data.docs = DocList[input_doc_list_model]([data])
+                    req.direct_docs = DocList[input_doc_list_model]([data])
                 if body.header is None:
                     req.header.request_id = req.docs[0].id
             _end = default_timer()
@@ -136,7 +136,6 @@ async def post(body: input_model, response: Response):
                     docs_response = resp.docs.to_dict()
                 else:
                     docs_response = resp.docs
-
                 ret = output_model(data=docs_response, parameters=resp.parameters)
                 _end = default_timer()
                 logger.info(
@@ -169,10 +168,10 @@ async def streaming_get(request: Request = None, body: input_doc_model = None):
             req = DataRequest()
             req.header.exec_endpoint = endpoint_path
             if not docarray_v2:
-                req.data.docs = DocumentArray([body])
+                req.direct_docs = DocumentArray([body])
             else:
                 req.document_array_cls = DocList[input_doc_model]
-                req.data.docs = DocList[input_doc_model]([body])
+                req.direct_docs = DocList[input_doc_model]([body])
             event_generator = _gen_dict_documents(await caller(req))
             return EventSourceResponse(event_generator)
 

diff --git a/jina/serve/runtimes/worker/request_handling.py b/jina/serve/runtimes/worker/request_handling.py
@@ -178,7 +178,7 @@ def call_handle(request):
                 'is_generator'
             ]
 
-            return self.process_single_data(request, None, is_generator=is_generator)
+            return self.process_single_data(request, None, http=True, is_generator=is_generator)
 
         app = get_fastapi_app(
             request_models_map=request_models_map, caller=call_handle, **kwargs
@@ -202,7 +202,7 @@ def call_handle(request):
                 'is_generator'
             ]
 
-            return self.process_single_data(request, None, is_generator=is_generator)
+            return self.process_single_data(request, None, http=True, is_generator=is_generator)
 
         app = get_fastapi_app(
             request_models_map=request_models_map, caller=call_handle, **kwargs
@@ -549,7 +549,7 @@ def _record_response_size_monitoring(self, requests):
                 requests[0].nbytes, attributes=attributes
             )
 
-    def _set_result(self, requests, return_data, docs):
+    def _set_result(self, requests, return_data, docs, http=False):
         # assigning result back to request
         if return_data is not None:
             if isinstance(return_data, DocumentArray):
@@ -569,10 +569,12 @@ def _set_result(self, requests, return_data, docs):
                     f'The return type must be DocList / Dict / `None`, '
                     f'but getting {return_data!r}'
                 )
-
-        WorkerRequestHandler.replace_docs(
-            requests[0], docs, self.args.output_array_type
-        )
+        if not http:
+            WorkerRequestHandler.replace_docs(
+                requests[0], docs, self.args.output_array_type
+            )
+        else:
+            requests[0].direct_docs = docs
         return docs
 
     def _setup_req_doc_array_cls(self, requests, exec_endpoint, is_response=False):
@@ -660,11 +662,12 @@ async def handle_generator(
         )
 
     async def handle(
-        self, requests: List['DataRequest'], tracing_context: Optional['Context'] = None
+        self, requests: List['DataRequest'], http=False, tracing_context: Optional['Context'] = None
     ) -> DataRequest:
         """Initialize private parameters and execute private loading functions.
 
         :param requests: The messages to handle containing a DataRequest
+        :param http: Flag indicating if it is used by the HTTP server for some optims
         :param tracing_context: Optional OpenTelemetry tracing context from the originating request.
         :returns: the processed message
         """
@@ -726,7 +729,7 @@ async def handle(
                 tracing_context=tracing_context,
             )
             _start = default_timer()
-            _ = self._set_result(requests, return_data, docs)
+            _ = self._set_result(requests, return_data, docs, http=http)
 
         for req in requests:
             req.add_executor(self.deployment_name)
@@ -915,18 +918,19 @@ def reduce_requests(requests: List['DataRequest']) -> 'DataRequest':
 
     # serving part
     async def process_single_data(
-        self, request: DataRequest, context, is_generator: bool = False
+        self, request: DataRequest, context, http: bool = False, is_generator: bool = False
     ) -> DataRequest:
         """
         Process the received requests and return the result as a new request
 
         :param request: the data request to process
         :param context: grpc context
+        :param http: Flag indicating if it is used by the HTTP server for some optims
         :param is_generator: whether the request should be handled with streaming
         :returns: the response request
         """
         self.logger.debug('recv a process_single_data request')
-        return await self.process_data([request], context, is_generator=is_generator)
+        return await self.process_data([request], context, http=http, is_generator=is_generator)
 
     async def stream_doc(
         self, request: SingleDocumentRequest, context: 'grpc.aio.ServicerContext'
@@ -1071,13 +1075,14 @@ def _extract_tracing_context(
         return None
 
     async def process_data(
-        self, requests: List[DataRequest], context, is_generator: bool = False
+        self, requests: List[DataRequest], context, http=False, is_generator: bool = False
     ) -> DataRequest:
         """
         Process the received requests and return the result as a new request
 
         :param requests: the data requests to process
         :param context: grpc context
+        :param http: Flag indicating if it is used by the HTTP server for some optims
         :param is_generator: whether the request should be handled with streaming
         :returns: the response request
         """
@@ -1100,11 +1105,11 @@ async def process_data(
 
                 if is_generator:
                     result = await self.handle_generator(
-                        requests=requests, tracing_context=tracing_context
+                        requests=requests,tracing_context=tracing_context
                     )
                 else:
                     result = await self.handle(
-                        requests=requests, tracing_context=tracing_context
+                        requests=requests, http=http, tracing_context=tracing_context
                     )
 
                 if self._successful_requests_metrics:

diff --git a/jina/types/request/data.py b/jina/types/request/data.py
@@ -114,6 +114,8 @@ def __init__(
         self._pb_body = None
         self._document_array_cls = DocumentArray
         self._data = None
+        # to be used to bypass proto extra transforms
+        self.direct_docs = None
 
         try:
             if isinstance(request, jina_pb2.DataRequestProto):
@@ -275,7 +277,10 @@ def docs(self) -> 'DocumentArray':
         """Get the :class: `DocumentArray` with sequence `data.docs` as content.
 
         .. # noqa: DAR201"""
-        return self.data.docs
+        if self.direct_docs is not None:
+            return self.direct_docs
+        else:
+            return self.data.docs
 
     @property
     def data(self) -> 'DataRequest._DataContent':
@@ -441,6 +446,8 @@ def __init__(
         self._document_cls = Document
         self.buffer = None
         self._data = None
+        # to be used to bypass proto extra transforms
+        self.direct_doc = None
 
         try:
             if isinstance(request, jina_pb2.SingleDocumentRequestProto):
@@ -606,7 +613,10 @@ def doc(self) -> 'Document':
         """Get the :class: `DocumentArray` with sequence `data.docs` as content.
 
         .. # noqa: DAR201"""
-        return self.data.doc
+        if self.direct_doc is not None:
+            return self.direct_doc
+        else:
+            return self.data.doc
 
     @property
     def data(self) -> 'SingleDocumentRequest._DataContent':

diff --git a/tests/integration/dynamic_batching/test_dynamic_batching.py b/tests/integration/dynamic_batching/test_dynamic_batching.py
@@ -528,7 +528,7 @@ def _assert_all_docs_processed(port, num_docs, endpoint):
         target=f'0.0.0.0:{port}',
         endpoint=endpoint,
     )
-    docs = resp.data.docs
+    docs = resp.docs
     assert docs.texts == ['long timeout' for _ in range(num_docs)]
 
 

diff --git a/tests/integration/inspect_deployments_flow/test_inspect_deployments_flow.py b/tests/integration/inspect_deployments_flow/test_inspect_deployments_flow.py
@@ -145,7 +145,7 @@ def test_flow_returned_collect(protocol, port_generator):
     def validate_func(resp):
         num_evaluations = 0
         scores = set()
-        for doc in resp.data.docs:
+        for doc in resp.docs:
             num_evaluations += len(doc.evaluations)
             scores.add(doc.evaluations['evaluate'].value)
         assert num_evaluations == 1

diff --git a/tests/unit/serve/dynamic_batching/test_batch_queue.py b/tests/unit/serve/dynamic_batching/test_batch_queue.py
@@ -27,7 +27,7 @@ async def foo(docs, **kwargs):
     three_data_requests = [DataRequest() for _ in range(3)]
     for req in three_data_requests:
         req.data.docs = DocumentArray.empty(1)
-        assert req.data.docs[0].text == ''
+        assert req.docs[0].text == ''
 
     async def process_request(req):
         q = await bq.push(req)
@@ -42,20 +42,20 @@ async def process_request(req):
     assert time_spent >= 2000
     # Test that since no more docs arrived, the function was triggerred after timeout
     for resp in responses:
-        assert resp.data.docs[0].text == 'Done'
+        assert resp.docs[0].text == 'Done'
 
     four_data_requests = [DataRequest() for _ in range(4)]
     for req in four_data_requests:
         req.data.docs = DocumentArray.empty(1)
-        assert req.data.docs[0].text == ''
+        assert req.docs[0].text == ''
     init_time = time.time()
     tasks = [asyncio.create_task(process_request(req)) for req in four_data_requests]
     responses = await asyncio.gather(*tasks)
     time_spent = (time.time() - init_time) * 1000
     assert time_spent < 2000
     # Test that since no more docs arrived, the function was triggerred after timeout
     for resp in responses:
-        assert resp.data.docs[0].text == 'Done'
+        assert resp.docs[0].text == 'Done'
 
     await bq.close()
 
@@ -135,7 +135,7 @@ async def foo(docs, **kwargs):
     data_requests = [DataRequest() for _ in range(3)]
     for req in data_requests:
         req.data.docs = DocumentArray.empty(10)  # 30 docs in total
-        assert req.data.docs[0].text == ''
+        assert req.docs[0].text == ''
 
     async def process_request(req):
         q = await bq.push(req)
@@ -150,7 +150,7 @@ async def process_request(req):
     assert time_spent < 2000
     # Test that since no more docs arrived, the function was triggerred after timeout
     for resp in responses:
-        assert resp.data.docs[0].text == 'Done'
+        assert resp.docs[0].text == 'Done'
 
     await bq.close()
 
@@ -196,9 +196,9 @@ async def process_request(req):
             assert isinstance(item, Exception)
     for i, req in enumerate(data_requests):
         if i not in BAD_REQUEST_IDX:
-            assert req.data.docs[0].text == f'{i} Processed'
+            assert req.docs[0].text == f'{i} Processed'
         else:
-            assert req.data.docs[0].text == 'Bad'
+            assert req.docs[0].text == 'Bad'
 
 
 @pytest.mark.asyncio
@@ -246,11 +246,11 @@ async def process_request(req):
             assert isinstance(item, Exception)
     for i, req in enumerate(data_requests):
         if i not in EXPECTED_BAD_REQUESTS:
-            assert req.data.docs[0].text == 'Processed'
+            assert req.docs[0].text == 'Processed'
         elif i in TRIGGER_BAD_REQUEST_IDX:
-            assert req.data.docs[0].text == 'Bad'
+            assert req.docs[0].text == 'Bad'
         else:
-            assert req.data.docs[0].text == ''
+            assert req.docs[0].text == ''
 
 
 @pytest.mark.asyncio
Original file line number	Diff line number	Diff line change
		@@ -1 +1 @@
		[{"version": "v3.26.0"}, {"version": "v3.25.2"}, {"version": "v3.25.1"}, {"version": "v3.25.0"}, {"version": "v3.24.1"}, {"version": "v3.24.0"}, {"version": "v3.23.5"}, {"version": "v3.23.4"}, {"version": "v3.23.3"}, {"version": "v3.23.2"}, {"version": "v3.23.1"}, {"version": "v3.23.0"}, {"version": "v3.22.4"}, {"version": "v3.22.3"}, {"version": "v3.22.2"}, {"version": "v3.22.1"}, {"version": "v3.22.0"}, {"version": "v3.21.1"}, {"version": "v3.21.0"}, {"version": "v3.20.3"}, {"version": "v3.20.2"}, {"version": "v3.20.1"}, {"version": "v3.20.0"}, {"version": "v3.19.1"}, {"version": "v3.19.0"}, {"version": "v3.18.0"}, {"version": "v3.17.0"}, {"version": "v3.16.1"}, {"version": "v3.16.0"}, {"version": "v3.15.2"}, {"version": "v3.15.0"}, {"version": "v3.14.1"}, {"version": "v3.14.0"}, {"version": "v3.13.1"}, {"version": "v3.13.0"}, {"version": "v3.12.0"}, {"version": "v3.11.0"}, {"version": "v3.10.1"}, {"version": "v3.10.0"}, {"version": "v3.9.3"}, {"version": "v3.9.2"}, {"version": "v3.9.1"}, {"version": "v3.9.0"}, {"version": "v3.8.4"}, {"version": "v3.8.0"}, {"version": "v3.7.14"}, {"version": "v3.7.0"}, {"version": "v3.6.16"}, {"version": "v3.6.1"}, {"version": "v3.6.0"}, {"version": "v3.5.0"}, {"version": "v3.4.11"}, {"version": "v3.4.0"}, {"version": "v3.3.25"}, {"version": "v3.3.0"}, {"version": "v3.2.10"}, {"version": "v3.2.0"}]
		[{"version": "v3.27.0"}, {"version": "v3.26.0"}, {"version": "v3.25.2"}, {"version": "v3.25.1"}, {"version": "v3.25.0"}, {"version": "v3.24.1"}, {"version": "v3.24.0"}, {"version": "v3.23.5"}, {"version": "v3.23.4"}, {"version": "v3.23.3"}, {"version": "v3.23.2"}, {"version": "v3.23.1"}, {"version": "v3.23.0"}, {"version": "v3.22.4"}, {"version": "v3.22.3"}, {"version": "v3.22.2"}, {"version": "v3.22.1"}, {"version": "v3.22.0"}, {"version": "v3.21.1"}, {"version": "v3.21.0"}, {"version": "v3.20.3"}, {"version": "v3.20.2"}, {"version": "v3.20.1"}, {"version": "v3.20.0"}, {"version": "v3.19.1"}, {"version": "v3.19.0"}, {"version": "v3.18.0"}, {"version": "v3.17.0"}, {"version": "v3.16.1"}, {"version": "v3.16.0"}, {"version": "v3.15.2"}, {"version": "v3.15.0"}, {"version": "v3.14.1"}, {"version": "v3.14.0"}, {"version": "v3.13.1"}, {"version": "v3.13.0"}, {"version": "v3.12.0"}, {"version": "v3.11.0"}, {"version": "v3.10.1"}, {"version": "v3.10.0"}, {"version": "v3.9.3"}, {"version": "v3.9.2"}, {"version": "v3.9.1"}, {"version": "v3.9.0"}, {"version": "v3.8.4"}, {"version": "v3.8.0"}, {"version": "v3.7.14"}, {"version": "v3.7.0"}, {"version": "v3.6.16"}, {"version": "v3.6.1"}, {"version": "v3.6.0"}, {"version": "v3.5.0"}, {"version": "v3.4.11"}, {"version": "v3.4.0"}, {"version": "v3.3.25"}, {"version": "v3.3.0"}, {"version": "v3.2.10"}, {"version": "v3.2.0"}]