diff --git a/v2/nacos/redo/abstract_redo_service.py b/v2/nacos/redo/abstract_redo_service.py
index 0acdb16..8bdef1b 100644
--- a/v2/nacos/redo/abstract_redo_service.py
+++ b/v2/nacos/redo/abstract_redo_service.py
@@ -22,6 +22,7 @@ def __init__(self, module:str):
 
 	async def on_connected(self) -> None:
 		self._connected = True
+		await self.start_redo_task()
 
 	async def on_disconnect(self) -> None:
 		self._connected = False
diff --git a/v2/nacos/transport/rpc_client.py b/v2/nacos/transport/rpc_client.py
index b46710a..5543449 100644
--- a/v2/nacos/transport/rpc_client.py
+++ b/v2/nacos/transport/rpc_client.py
@@ -459,7 +459,7 @@ async def request_reply(self, request: Request) -> Optional[ConnectResetResponse
             return None
 
         try:
-            with self.rpc_client.lock:
+            async with self.rpc_client.lock:
                 if self.rpc_client.is_running():
                     if request.server_ip.strip():
                         server_info = ServerInfo(request.server_ip, int(request.server_port))