Make logger a constant by uppercasing it

Author: jonathan343

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

@@ -26,7 +26,7 @@
 )
 from smithy_core.traits import EventHeaderTrait
 
-logger = logging.getLogger(__name__)
+LOGGER = logging.getLogger(__name__)
 
 INITIAL_MESSAGE_TYPES = (INITIAL_REQUEST_EVENT_TYPE, INITIAL_RESPONSE_EVENT_TYPE)
 
@@ -47,17 +47,17 @@ def __init__(
     async def receive(self) -> E | None:
         event = await Event.decode_async(self._source)
         if event is None:
-            logger.debug("No event received from the source.")
+            LOGGER.debug("No event received from the source.")
             return None
-        logger.debug("Received raw event: %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("Successfully deserialized event: %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

@@ -30,7 +30,7 @@
 )
 from smithy_core.traits import ErrorTrait, EventHeaderTrait, MediaTypeTrait
 
-logger = logging.getLogger(__name__)
+LOGGER = logging.getLogger(__name__)
 
 _DEFAULT_STRING_CONTENT_TYPE = "text/plain"
 _DEFAULT_BLOB_CONTENT_TYPE = "application/octet-stream"
@@ -55,7 +55,7 @@ def __init__(
         )
 
     async def send(self, event: E) -> None:
-        logger.debug("Preparing to publish event: %s", event)
+        LOGGER.debug("Preparing to publish event: %s", event)
         event.serialize(self._serializer)
         result = self._serializer.get_result()
         if result is None:
@@ -64,7 +64,7 @@ async def send(self, event: E) -> None:
             )
         if self._signer is not None:
             result = self._signer(result)
-        logger.debug("Publishing serialized event: %s", result)
+        LOGGER.debug("Publishing serialized event: %s", result)
         await self._writer.write(result.encode())
 
     async def close(self) -> None: