version from 5.0.2 to 5.0.3

Author: zhouli

python/rocketmq/v5/client/client.py

@@ -285,7 +285,7 @@ def _retrieve_topic_route_data(self, topic):
                 self.__topics.add(topic)
                 return route
             else:
-                raise Exception(f"retrieve topic:{topic} route, but route is None.")
+                raise Exception(f"failed to fetch topic:{topic} route.")
 
     def _remove_unused_topic_route_data(self, topic):
         self.__topic_route_cache.remove(topic)

python/rocketmq/v5/client/connection/rpc_channel.py

@@ -15,6 +15,7 @@
 
 import asyncio
 import time
+
 import grpc
 from grpc import ChannelConnectivity, aio
 from grpc.aio import AioRpcError

python/rocketmq/v5/client/connection/rpc_client.py

@@ -59,15 +59,15 @@ def retrieve_or_create_channel(self, endpoints: RpcEndpoints):
             raise Exception("RpcClient is not running.")
         try:
             # get or create a new grpc channel
-                channel = self.__get_channel(endpoints)
-                if channel is not None:
-                    channel.update_time = int(time.time())
-                else:
-                    with RpcClient._channel_lock:
-                        channel = RpcChannel(endpoints, self.__tls_enable)
-                        channel.create_channel(RpcClient.get_channel_io_loop())
-                        self.__put_channel(endpoints, channel)
-                return channel
+            channel = self.__get_channel(endpoints)
+            if channel is not None:
+                channel.update_time = int(time.time())
+            else:
+                with RpcClient._channel_lock:
+                    channel = RpcChannel(endpoints, self.__tls_enable)
+                    channel.create_channel(RpcClient.get_channel_io_loop())
+                    self.__put_channel(endpoints, channel)
+            return channel
         except Exception as e:
             logger.error(f"retrieve or create channel exception: {e}")
             raise e
@@ -139,7 +139,7 @@ def notify_client_termination(self, endpoints: RpcEndpoints, req: NotifyClientTe
 
     def end_transaction_for_server_check(self, endpoints: RpcEndpoints, req: EndTransactionRequest, metadata,
                                          timeout=3):
-        ## assert asyncio.get_running_loop() == RpcClient._io_loop
+        # assert asyncio.get_running_loop() == RpcClient._io_loop
         try:
             return self.__end_transaction_0(endpoints, req, metadata=metadata, timeout=timeout)
         except Exception as e:
@@ -204,7 +204,6 @@ async def __notify_client_termination_0(self, endpoints: RpcEndpoints, req: Noti
     async def __create_channel_async(self, endpoints: RpcEndpoints):
         return self.retrieve_or_create_channel(endpoints)
 
-
     """ private """
 
     def __get_channel(self, endpoints: RpcEndpoints) -> RpcChannel:

python/rocketmq/v5/util/misc.py

@@ -29,7 +29,7 @@ class Misc:
     __OS_NAME = None
     TOPIC_PATTERN = compile(r'^[%a-zA-Z0-9_-]+$')
     CONSUMER_GROUP_PATTERN = compile(r'^[%a-zA-Z0-9_-]+$')
-    SDK_VERSION = "5.0.2"
+    SDK_VERSION = "5.0.3"
 
     @staticmethod
     def sdk_language():

python/setup.py

@@ -17,7 +17,7 @@
 
 setup(
     name='rocketmq-python-client',
-    version='5.0.2',
+    version='5.0.3',
     packages=find_packages(),
     install_requires=[
         "grpcio>=1.5.0",