Update logger messages

Author: jonathan343

packages/aws-event-stream/src/aws_event_stream/_private/deserializers.py

@@ -58,16 +58,17 @@ async def receive(self) -> E | None:
             raise
 
         if event is None:
+            logger.debug("No event received from the source.")
             return None
-        logger.debug("Received raw event message: %s", event)
+        logger.debug("Received raw event: %s", event)
 
         deserializer = EventDeserializer(
             event=event,
             payload_codec=self._payload_codec,
             is_client_mode=self._is_client_mode,
         )
         result = self._deserializer(deserializer)
-        logger.debug("Deserialized event message: %s", result)
+        logger.debug("Successfully deserialized event: %s", result)
         if isinstance(getattr(result, "value"), Exception):
             raise result.value  # type: ignore
         return result

packages/aws-event-stream/src/aws_event_stream/_private/serializers.py

@@ -58,7 +58,7 @@ def __init__(
     async def send(self, event: E) -> None:
         if self._closed:
             raise IOError("Attempted to write to closed stream.")
-        logger.debug("Raw event message: %s", event)
+        logger.debug("Preparing to publish event: %s", event)
         event.serialize(self._serializer)
         result = self._serializer.get_result()
         if result is None:
@@ -70,7 +70,7 @@ async def send(self, event: E) -> None:
 
         encoded_result = result.encode()
         try:
-            logger.debug("Writing event message: %s", result)
+            logger.debug("Publishing serialized event: %s", result)
             await self._writer.write(encoded_result)
         except Exception as e:
             await self.close()