chore: 测试

Author: SilianZ

core/__init__.py

@@ -50,8 +50,8 @@ async def syncFiles():
         logger.tinfo("main.info.stopping")
         if cluster.enabled:
             await cluster.disable()
-        if cluster.socket:
-            await cluster.socket.socket.disconnect()
+        # if cluster.socket:
+        #     await cluster.socket.socket.disconnect()
         if cluster.site:
             await cluster.site.stop()
         if scheduler.state == 1:

core/cluster.py

@@ -382,7 +382,7 @@ async def callback(data: List[Any]):
             logger.terror("cluster.error.keep_alive.error", e=e)
 
     async def disable(self) -> None:
-        if not self.socket or not self.enabled or not self.socket.socket.connected:
+        if not self.socket or not self.enabled:
             return
         logger.tinfo("cluster.info.disabling")
         future = asyncio.Future()