From e7ccf3474fbc751c1c3f24d9c8125e1f986ccaa9 Mon Sep 17 00:00:00 2001 From: Evan Date: Fri, 28 Nov 2025 17:28:12 +0000 Subject: [PATCH] logging --- src/exo/master/main.py | 2 +- src/exo/routing/router.py | 5 +++-- src/exo/worker/main.py | 2 +- 3 files changed, 5 insertions(+), 4 deletions(-) diff --git a/src/exo/master/main.py b/src/exo/master/main.py index 49e734d4..3c851f9d 100644 --- a/src/exo/master/main.py +++ b/src/exo/master/main.py @@ -232,7 +232,7 @@ class Master: local_event.origin, ) for event in self._multi_buffer.drain(): - logger.debug(f"Master indexing event: {str(event)[:100]}") + logger.trace(f"Master indexing event: {str(event)[:100]}") indexed = IndexedEvent(event=event, idx=len(self._event_log)) self.state = apply(self.state, indexed) diff --git a/src/exo/routing/router.py b/src/exo/routing/router.py index 38609c68..f29d28db 100644 --- a/src/exo/routing/router.py +++ b/src/exo/routing/router.py @@ -69,8 +69,9 @@ class TopicRouter[T: CamelCaseModel]: async def net_receive_loop(self): assert self.networking_receiver is not None while True: - item = await self.networking_receiver.receive() - await self.publish(self.topic.deserialize(item)) + item = self.topic.deserialize(await self.networking_receiver.receive()) + logger.debug(f"Got {item} from network") + await self.publish(item) def subscribe_with(self, net_send: RustSender, net_recv: RustReceiver): self.networking_sender = net_send diff --git a/src/exo/worker/main.py b/src/exo/worker/main.py index b87f819c..6479f3f1 100644 --- a/src/exo/worker/main.py +++ b/src/exo/worker/main.py @@ -379,7 +379,7 @@ class Worker: session=self.session_id, event=event, ) - logger.debug( + logger.trace( f"Worker published event {self.local_event_index}: {str(event)[:100]}" ) self.local_event_index += 1