chore: remove annoying message for debug (jina-ai#5901)

Signed-off-by: Joan Fontanals Martinez <[email protected]>

Author: JoanFM

jina/serve/consensus/jina_raft/rpc.go

@@ -103,7 +103,6 @@ func (rpc *RpcInterface) ProcessSingleData(
         }
         response, test := future.Response().(*pb.DataRequestProto)
         if test {
-            rpc.Logger.Debug("Return from RAFT Apply:", "Response", response.String())
             return response, nil
         } else {
             err := future.Response().(error)

jina/serve/networking/__init__.py

@@ -339,8 +339,10 @@ async def _handle_aiorpcerror(
         # if an Executor is down behind an API gateway, grpc.StatusCode.NOT_FOUND is returned
         # requests usually gets cancelled when the server shuts down
         # retries for cancelled requests will hit another replica in K8s
+        skip_resetting = False
         if error.code() == grpc.StatusCode.UNAVAILABLE and 'not the leader' in error.details():
             self._logger.debug(f'RAFT node of {current_deployment} is not the leader. Trying next replica, if available.')
+            skip_resetting = True # no need to reset, no problem with channel
         else:
             self._logger.debug(
                 f'gRPC call to {current_deployment} errored, with error {format_grpc_error(error)} and for the {retry_i + 1}th time.'
@@ -366,7 +368,7 @@ async def _handle_aiorpcerror(
 
             # after connection failure the gRPC `channel` gets stuck in a failure state for a few seconds
             # removing and re-adding the connection (stub) is faster & more reliable than just waiting
-            if connection_list:
+            if connection_list and not skip_resetting:
                 await connection_list.reset_connection(
                     current_address, current_deployment
                 )
@@ -378,7 +380,7 @@ async def _handle_aiorpcerror(
                 details=error.details(),
             )
         else:
-            if connection_list:
+            if connection_list and not skip_resetting:
                 await connection_list.reset_connection(
                     current_address, current_deployment
                 )