From 6e30cbb345050cef5d87066b599978831f374f67 Mon Sep 17 00:00:00 2001 From: "bodong.yang" Date: Thu, 5 Dec 2024 03:15:02 +0000 Subject: [PATCH] minor update --- src/otaclient/grpc/api_v2/servicer.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/otaclient/grpc/api_v2/servicer.py b/src/otaclient/grpc/api_v2/servicer.py index 87f02d2f1..79d7baaa6 100644 --- a/src/otaclient/grpc/api_v2/servicer.py +++ b/src/otaclient/grpc/api_v2/servicer.py @@ -36,7 +36,7 @@ logger = logging.getLogger(__name__) -WAIT_FOR_ACK_TIMEOUT = 6 # seconds +WAIT_FOR_LOCAL_ECU_ACK_TIMEOUT = 6 # seconds class OTAClientAPIServicer: @@ -70,7 +70,7 @@ def __init__( def _local_update(self, request: UpdateRequestV2) -> api_types.UpdateResponseEcu: self._op_queue.put_nowait(request) try: - _req_response = self._resp_queue.get(timeout=WAIT_FOR_ACK_TIMEOUT) + _req_response = self._resp_queue.get(timeout=WAIT_FOR_LOCAL_ECU_ACK_TIMEOUT) assert isinstance(_req_response, IPCResponse), "unexpected msg" assert ( _req_response.session_id == request.session_id @@ -179,7 +179,7 @@ def _local_rollback( ) -> api_types.RollbackResponseEcu: self._op_queue.put_nowait(rollback_request) try: - _req_response = self._resp_queue.get(timeout=WAIT_FOR_ACK_TIMEOUT) + _req_response = self._resp_queue.get(timeout=WAIT_FOR_LOCAL_ECU_ACK_TIMEOUT) assert isinstance( _req_response, IPCResponse ), f"unexpected response: {type(_req_response)}"