diff --git a/src/pipecat/services/deepgram/flux/stt.py b/src/pipecat/services/deepgram/flux/stt.py
index a561c9ae3..74e9d1053 100644
--- a/src/pipecat/services/deepgram/flux/stt.py
+++ b/src/pipecat/services/deepgram/flux/stt.py
@@ -245,8 +245,7 @@ class DeepgramFluxSTTService(WebsocketSTTService):
             )
 
             headers = {
-                k: v for k, v in self._websocket.response.headers.items()
-                if k.startswith("dg-")
+                k: v for k, v in self._websocket.response.headers.items() if k.startswith("dg-")
             }
             logger.debug(f'{self}: Websocket connection initialized: {{"headers": {headers}}}')
 
diff --git a/src/pipecat/services/deepgram/stt.py b/src/pipecat/services/deepgram/stt.py
index 4006766fb..11be561b1 100644
--- a/src/pipecat/services/deepgram/stt.py
+++ b/src/pipecat/services/deepgram/stt.py
@@ -236,7 +236,8 @@ class DeepgramSTTService(STTService):
             await self.push_error(error_msg=f"Unable to connect to Deepgram")
         else:
             headers = {
-                k: v for k, v in self._connection._socket.response.headers.items()
+                k: v
+                for k, v in self._connection._socket.response.headers.items()
                 if k.startswith("dg-")
             }
             logger.debug(f'{self}: Websocket connection initialized: {{"headers": {headers}}}')
diff --git a/src/pipecat/services/deepgram/tts.py b/src/pipecat/services/deepgram/tts.py
index 51342335e..0f555109e 100644
--- a/src/pipecat/services/deepgram/tts.py
+++ b/src/pipecat/services/deepgram/tts.py
@@ -285,11 +285,7 @@ class DeepgramTTSService(WebsocketTTSService):
                 {"text": text}, options
             )
 
-            headers = {
-                k: v
-                for k, v in response.headers.items()
-                if k.startswith("dg-")
-            }
+            headers = {k: v for k, v in response.headers.items() if k.startswith("dg-")}
             logger.debug(f'{self}: HTTP connection initialized: {{"headers": {headers}}}')
 
             await self.start_tts_usage_metrics(text)