Add logging to subscribe method
All checks were successful
Blockchain Synchronization Verification / sync-verification (push) Successful in 3s
Integration Tests / test-service-integration (push) Successful in 59s
Multi-Node Blockchain Health Monitoring / health-check (push) Successful in 3s
P2P Network Verification / p2p-verification (push) Successful in 7s
Python Tests / test-python (push) Successful in 24s
Security Scanning / security-scan (push) Successful in 26s
All checks were successful
Blockchain Synchronization Verification / sync-verification (push) Successful in 3s
Integration Tests / test-service-integration (push) Successful in 59s
Multi-Node Blockchain Health Monitoring / health-check (push) Successful in 3s
P2P Network Verification / p2p-verification (push) Successful in 7s
Python Tests / test-python (push) Successful in 24s
Security Scanning / security-scan (push) Successful in 26s
This commit is contained in:
@@ -143,6 +143,9 @@ class BroadcastGossipBackend(GossipBackend):
|
||||
_increment_publication("gossip_broadcast_publications", topic)
|
||||
|
||||
async def subscribe(self, topic: str, max_queue_size: int = 100) -> TopicSubscription:
|
||||
import logging
|
||||
logger = logging.getLogger(__name__)
|
||||
logger.info(f"BroadcastGossipBackend.subscribe called for topic: {topic}, running={self._running}")
|
||||
if not self._running:
|
||||
raise RuntimeError("Broadcast backend not started")
|
||||
|
||||
|
||||
Reference in New Issue
Block a user