From 02d090cb94b4bfcee581dbf3c8a96253e05be5dd Mon Sep 17 00:00:00 2001 From: Koushik Dutta Date: Wed, 13 Nov 2024 15:09:18 -0800 Subject: [PATCH] server: fix python cluster server loop missing --- server/python/plugin_remote.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/server/python/plugin_remote.py b/server/python/plugin_remote.py index 4bd8517d7..b218afa99 100644 --- a/server/python/plugin_remote.py +++ b/server/python/plugin_remote.py @@ -562,7 +562,8 @@ def getClusterPeerKey(address: str, port: int): return f"{address}:{port}" class ClusterSetup(): - def __init__(self, peer: rpc.RpcPeer): + def __init__(self, loop: AbstractEventLoop, peer: rpc.RpcPeer): + self.loop = loop self.peer = peer self.clusterId: str = None self.clusterSecret: str = None @@ -1180,7 +1181,7 @@ async def plugin_async_main( peer, readLoop = await rpc_reader.prepare_peer_readloop(loop, rpcTransport) peer.params["print"] = print - clusterSetup = ClusterSetup(peer) + clusterSetup = ClusterSetup(loop, peer) peer.params["initializeCluster"] = lambda options: clusterSetup.initializeCluster(options) peer.params["getRemote"] = lambda api, pluginId, hostInfo: PluginRemote(