chore(lint): apply automatic linting fixes to examples

- Fix import ordering (ruff isort)
- Remove trailing whitespace
- Remove trailing blank lines
- Format code according to project standards

Author: lukeocodes

examples/01-authentication-api-key.py

@@ -20,4 +20,3 @@
 # client = DeepgramClient(api_key="your-api-key-here")
 
 print("Client initialized with API key")
-

examples/02-authentication-access-token.py

@@ -25,4 +25,3 @@
 # client = DeepgramClient()
 
 print("Client initialized with access token")
-

examples/04-transcription-prerecorded-url.py

@@ -19,20 +19,20 @@
         url="https://dpgr.am/spacewalk.wav",
         model="nova-3",
     )
-    
+
     print("Transcription received:")
     if response.results and response.results.channels:
         transcript = response.results.channels[0].alternatives[0].transcript
         print(transcript)
-    
+
     # For async version:
     # from deepgram import AsyncDeepgramClient
     # client = AsyncDeepgramClient()
     # response = await client.listen.v1.media.transcribe_url(...)
-    
+
     # With access token:
     # client = DeepgramClient(access_token="your-access-token")
-    
+
     # With additional query parameters:
     # response = client.listen.v1.media.transcribe_url(
     #     url="https://dpgr.am/spacewalk.wav",
@@ -43,7 +43,6 @@
     #         }
     #     }
     # )
-    
+
 except Exception as e:
     print(f"Error: {e}")
-

examples/05-transcription-prerecorded-file.py

@@ -5,6 +5,7 @@
 """
 
 import os
+
 from dotenv import load_dotenv
 
 load_dotenv()
@@ -17,17 +18,17 @@
     # Path to audio file
     script_dir = os.path.dirname(os.path.abspath(__file__))
     audio_path = os.path.join(script_dir, "fixtures", "audio.wav")
-    
+
     print(f"Reading audio file: {audio_path}")
     with open(audio_path, "rb") as audio_file:
         audio_data = audio_file.read()
-    
+
     print("Sending transcription request...")
     response = client.listen.v1.media.transcribe_file(
         request=audio_data,
         model="nova-3",
     )
-    
+
     # For large files, you can stream the file instead of loading it all into memory:
     # def read_file_in_chunks(file_path, chunk_size=8192):
     #     with open(file_path, "rb") as f:
@@ -40,17 +41,16 @@
     #     request=read_file_in_chunks(audio_path),
     #     model="nova-3",
     # )
-    
+
     print("Transcription received:")
     if response.results and response.results.channels:
         transcript = response.results.channels[0].alternatives[0].transcript
         print(transcript)
-    
+
     # For async version:
     # from deepgram import AsyncDeepgramClient
     # client = AsyncDeepgramClient()
     # response = await client.listen.v1.media.transcribe_file(...)
-    
+
 except Exception as e:
     print(f"Error: {e}")
-

examples/06-transcription-prerecorded-callback.py

@@ -20,17 +20,16 @@
         callback="https://your-callback-url.com/webhook",
         model="nova-3",
     )
-    
+
     # This returns a "listen accepted" response, not the full transcription
     # The actual transcription will be sent to your callback URL
     print(f"Request accepted. Request ID: {response.request_id}")
     print("Transcription will be sent to your callback URL when ready.")
-    
+
     # For async version:
     # from deepgram import AsyncDeepgramClient
     # client = AsyncDeepgramClient()
     # response = await client.listen.v1.media.transcribe_url(..., callback="...")
-    
+
 except Exception as e:
     print(f"Error: {e}")
-

examples/07-transcription-live-websocket.py

@@ -4,7 +4,6 @@
 This example shows how to stream audio for real-time transcription using WebSocket.
 """
 
-import os
 from typing import Union
 
 from dotenv import load_dotenv
@@ -26,17 +25,18 @@
 
 try:
     with client.listen.v1.connect(model="nova-3") as connection:
+
         def on_message(message: ListenV1SocketClientResponse) -> None:
             msg_type = getattr(message, "type", "Unknown")
             print(f"Received {msg_type} event")
-            
+
             # Extract transcription from Results events
             if isinstance(message, ListenV1Results):
                 if message.channel and message.channel.alternatives:
                     transcript = message.channel.alternatives[0].transcript
                     if transcript:
                         print(f"Transcript: {transcript}")
-        
+
         connection.on(EventType.OPEN, lambda _: print("Connection opened"))
         connection.on(EventType.MESSAGE, on_message)
         connection.on(EventType.CLOSE, lambda _: print("Connection closed"))
@@ -48,15 +48,14 @@ def on_message(message: ListenV1SocketClientResponse) -> None:
         # with open(audio_path, "rb") as audio_file:
         #     audio_data = audio_file.read()
         #     connection.send_listen_v_1_media(audio_data)
-        
+
         connection.start_listening()
-        
+
     # For async version:
     # from deepgram import AsyncDeepgramClient
     # async with client.listen.v1.connect(model="nova-3") as connection:
     #     # ... same event handlers ...
     #     await connection.start_listening()
-    
+
 except Exception as e:
     print(f"Error: {e}")
-

examples/09-voice-agent.py

@@ -11,7 +11,6 @@
 load_dotenv()
 
 from deepgram import DeepgramClient
-from deepgram.core.events import EventType
 from deepgram.agent.v1.types import (
     AgentV1Agent,
     AgentV1AudioConfig,
@@ -24,6 +23,7 @@
     AgentV1SpeakProviderConfig,
     AgentV1Think,
 )
+from deepgram.core.events import EventType
 
 AgentV1SocketClientResponse = Union[str, bytes]
 
@@ -53,7 +53,7 @@
                         model="gpt-4o-mini",
                         temperature=0.7,
                     ),
-                    prompt='You are a helpful AI assistant.',
+                    prompt="You are a helpful AI assistant.",
                 ),
                 speak=AgentV1SpeakProviderConfig(
                     provider=AgentV1DeepgramSpeakProvider(
@@ -74,7 +74,7 @@ def on_message(message: AgentV1SocketClientResponse) -> None:
             else:
                 msg_type = getattr(message, "type", "Unknown")
                 print(f"Received {msg_type} event")
-        
+
         agent.on(EventType.OPEN, lambda _: print("Connection opened"))
         agent.on(EventType.MESSAGE, on_message)
         agent.on(EventType.CLOSE, lambda _: print("Connection closed"))
@@ -85,16 +85,15 @@ def on_message(message: AgentV1SocketClientResponse) -> None:
         # with open("audio.wav", "rb") as audio_file:
         #     audio_data = audio_file.read()
         #     agent.send_agent_v_1_media(audio_data)
-        
+
         agent.start_listening()
-        
+
     # For async version:
     # from deepgram import AsyncDeepgramClient
     # async with client.agent.v1.connect() as agent:
     #     # ... same configuration ...
     #     await agent.send_agent_v_1_settings(settings)
     #     await agent.start_listening()
-    
+
 except Exception as e:
     print(f"Error: {e}")
-

examples/11-text-to-speech-streaming.py

@@ -12,14 +12,15 @@
 
 from deepgram import DeepgramClient
 from deepgram.core.events import EventType
-from deepgram.speak.v1.types import SpeakV1Text, SpeakV1Flush, SpeakV1Close
+from deepgram.speak.v1.types import SpeakV1Close, SpeakV1Flush, SpeakV1Text
 
 SpeakV1SocketClientResponse = Union[str, bytes]
 
 client = DeepgramClient()
 
 try:
     with client.speak.v1.connect(model="aura-2-asteria-en", encoding="linear16", sample_rate=24000) as connection:
+
         def on_message(message: SpeakV1SocketClientResponse) -> None:
             if isinstance(message, bytes):
                 print("Received audio data")
@@ -29,7 +30,7 @@ def on_message(message: SpeakV1SocketClientResponse) -> None:
             else:
                 msg_type = getattr(message, "type", "Unknown")
                 print(f"Received {msg_type} event")
-        
+
         connection.on(EventType.OPEN, lambda _: print("Connection opened"))
         connection.on(EventType.MESSAGE, on_message)
         connection.on(EventType.CLOSE, lambda _: print("Connection closed"))
@@ -40,19 +41,19 @@ def on_message(message: SpeakV1SocketClientResponse) -> None:
         # For better control with bidirectional communication, use the async version
         text_message = SpeakV1Text(text="Hello, this is a text to speech example.")
         connection.send_speak_v_1_text(text_message)
-        
+
         # Flush to ensure all text is processed
         flush_message = SpeakV1Flush()
         connection.send_speak_v_1_flush(flush_message)
-        
+
         # Close the connection when done
         close_message = SpeakV1Close()
         connection.send_speak_v_1_close(close_message)
-        
+
         # Start listening - this blocks until the connection closes
         # All messages should be sent before calling this in sync mode
         connection.start_listening()
-        
+
     # For async version:
     # from deepgram import AsyncDeepgramClient
     # async with client.speak.v1.connect(...) as connection:
@@ -61,7 +62,6 @@ def on_message(message: SpeakV1SocketClientResponse) -> None:
     #     await connection.send_speak_v_1_flush(SpeakV1Flush())
     #     await connection.send_speak_v_1_close(SpeakV1Close())
     #     await listen_task
-    
+
 except Exception as e:
     print(f"Error: {e}")
-

examples/12-text-intelligence.py

@@ -22,7 +22,7 @@
         topics=True,
         intents=True,
     )
-    
+
     print("Analysis received:")
     print(f"Sentiment: {response.sentiment}")
     if response.summary:
@@ -31,12 +31,11 @@
         print(f"Topics: {response.topics}")
     if response.intents:
         print(f"Intents: {response.intents}")
-    
+
     # For async version:
     # from deepgram import AsyncDeepgramClient
     # client = AsyncDeepgramClient()
     # response = await client.read.v1.text.analyze(...)
-    
+
 except Exception as e:
     print(f"Error: {e}")
-

examples/13-management-projects.py

@@ -17,36 +17,32 @@
     print("Listing all projects...")
     projects = client.manage.v1.projects.list()
     print(f"Found {len(projects.projects)} projects")
-    
+
     if projects.projects:
         project_id = projects.projects[0].project_id
         print(f"Using project: {project_id}")
-        
+
         # Get a specific project
-        print(f"\nGetting project details...")
+        print("\nGetting project details...")
         project = client.manage.v1.projects.get(project_id=project_id)
         print(f"Project name: {project.name}")
-        
+
         # Update project name
-        print(f"\nUpdating project name...")
-        updated = client.manage.v1.projects.update(
-            project_id=project_id,
-            name="Updated Project Name"
-        )
+        print("\nUpdating project name...")
+        updated = client.manage.v1.projects.update(project_id=project_id, name="Updated Project Name")
         print(f"Updated project name: {updated.name}")
-        
+
         # Note: Delete and leave operations are commented out for safety
         # Delete a project:
         # client.manage.v1.projects.delete(project_id=project_id)
-        
+
         # Leave a project:
         # client.manage.v1.projects.leave(project_id=project_id)
-    
+
     # For async version:
     # from deepgram import AsyncDeepgramClient
     # client = AsyncDeepgramClient()
     # projects = await client.manage.v1.projects.list()
-    
+
 except Exception as e:
     print(f"Error: {e}")
-