From 93c2d5002f30c60ab7f1b21d89af62ea25fc9c93 Mon Sep 17 00:00:00 2001 From: paschal533 Date: Tue, 2 Sep 2025 03:50:00 -0700 Subject: [PATCH] fix: GossipSub peer propagation to include FloodSub peers --- libp2p/pubsub/gossipsub.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libp2p/pubsub/gossipsub.py b/libp2p/pubsub/gossipsub.py index 45c6cd81..e92c457d 100644 --- a/libp2p/pubsub/gossipsub.py +++ b/libp2p/pubsub/gossipsub.py @@ -308,7 +308,7 @@ class GossipSub(IPubsubRouter, Service): floodsub_peers: set[ID] = { peer_id for peer_id in self.pubsub.peer_topics[topic] - if self.peer_protocol[peer_id] == floodsub.PROTOCOL_ID + if peer_id in self.peer_protocol and self.peer_protocol[peer_id] == floodsub.PROTOCOL_ID } send_to.update(floodsub_peers)