From 4e8cba203794f07e94a7ff30ac8d919db84e590c Mon Sep 17 00:00:00 2001 From: Conatum Date: Wed, 23 Aug 2023 09:44:55 +0300 Subject: [PATCH] fix (shardtalk): Fix broadcast peerlist. --- src/meta/ipc/client.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/meta/ipc/client.py b/src/meta/ipc/client.py index be0d43ca..d3d7f039 100644 --- a/src/meta/ipc/client.py +++ b/src/meta/ipc/client.py @@ -126,12 +126,12 @@ class AppClient: @log_wrap(action="Broadcast") async def requestall(self, payload, except_self=True, only_my_peers=True): - peerlist = self.my_peers if only_my_peers else self.peers + peerlist = list((self.my_peers if only_my_peers else self.peers).keys()) results = await asyncio.gather( *(self.request(appid, payload) for appid in peerlist if (appid != self.appid or not except_self)), return_exceptions=True ) - return dict(zip(self.peers.keys(), results)) + return dict(zip(peerlist, results)) async def handle_request(self, reader, writer): set_logging_context(action="SERV")