Fix lucky broadcast

Tribler · Sep 20, 2023 · a30007a · a30007a
1 parent e794c4d
commit a30007a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/bami/broadcast/community.py b/src/bami/broadcast/community.py
@@ -169,7 +169,8 @@ def lucky_broadcast(self, message_payload, num_nodes=None):
         """Broadcast message to all peers and return the awaited id for acknowledgement"""
         sample_size = num_nodes if num_nodes else self.settings.sync_retry_nodes
         lucky_peers = random.sample(self.get_full_nodes(), sample_size)
-        self.ez_send(lucky_peers, message_payload)
+        for peer in lucky_peers:
+            self.ez_send(peer, message_payload)
 
     @lazy_wrapper(TxBatchPayload)
     def receive_new_batch(self, p: Peer, batch: TxBatchPayload):