mirror of
https://github.com/exo-explore/exo.git
synced 2026-02-26 03:06:05 -05:00
Compare commits
1 Commits
remove-pyt
...
handle-mes
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c4d24a24e4 |
@@ -211,6 +211,14 @@ class Router:
|
|||||||
pass
|
pass
|
||||||
except AllQueuesFullError:
|
except AllQueuesFullError:
|
||||||
logger.warning(f"All peer queues full, dropping message on {topic}")
|
logger.warning(f"All peer queues full, dropping message on {topic}")
|
||||||
|
except RuntimeError as e:
|
||||||
|
if "MessageTooLarge" in str(e):
|
||||||
|
logger.error(
|
||||||
|
f"Message too large for gossipsub on topic {topic} "
|
||||||
|
f"({len(data)} bytes), dropping message"
|
||||||
|
)
|
||||||
|
else:
|
||||||
|
raise
|
||||||
|
|
||||||
|
|
||||||
def get_node_id_keypair(
|
def get_node_id_keypair(
|
||||||
|
|||||||
Reference in New Issue
Block a user