logging

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)
 

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

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