style: fix format issues in twilio_handler.py

Author: Shraman123

examples/realtime/twilio/twilio_handler.py

@@ -52,26 +52,22 @@ def __init__(self, twilio_websocket: WebSocket):
         # Audio chunking (matches CLI demo)
         self.CHUNK_LENGTH_S = 0.05  # 50ms chunks
         self.SAMPLE_RATE = 8000  # Twilio g711_ulaw at 8kHz
-        self.BUFFER_SIZE_BYTES = int(
-            self.SAMPLE_RATE * self.CHUNK_LENGTH_S
-        )  # ~400 bytes per 50ms
+        self.BUFFER_SIZE_BYTES = int(self.SAMPLE_RATE * self.CHUNK_LENGTH_S)  # ~400 bytes per 50ms
 
         self._stream_sid: str | None = None
         self._audio_buffer: bytearray = bytearray()
         self._last_buffer_send_time = time.time()
 
         # Playback tracking for outbound audio
         self._mark_counter = 0
-        self._mark_data: dict[str, tuple[str, int, int]] = (
-            {}
-        )  # mark_id -> (item_id, content_index, byte_count)
+        self._mark_data: dict[
+            str, tuple[str, int, int]
+        ] = {}  # mark_id -> (item_id, content_index, byte_count)
 
         # ---- Deterministic startup warm-up (preferred over sleep) ----
         # Buffer the first N chunks before sending to OpenAI; then mark warmed.
         try:
-            self.STARTUP_BUFFER_CHUNKS = max(
-                0, int(os.getenv("TWILIO_STARTUP_BUFFER_CHUNKS", "3"))
-            )
+            self.STARTUP_BUFFER_CHUNKS = max(0, int(os.getenv("TWILIO_STARTUP_BUFFER_CHUNKS", "3")))
         except Exception:
             self.STARTUP_BUFFER_CHUNKS = 3
 
@@ -243,9 +239,7 @@ async def _handle_mark_event(self, message: dict[str, Any]) -> None:
             if mark_id in self._mark_data:
                 item_id, item_content_index, byte_count = self._mark_data[mark_id]
                 audio_bytes = b"\x00" * byte_count  # Placeholder bytes for tracker
-                self.playback_tracker.on_play_bytes(
-                    item_id, item_content_index, audio_bytes
-                )
+                self.playback_tracker.on_play_bytes(item_id, item_content_index, audio_bytes)
                 print(
                     f"Playback tracker updated: {item_id}, index {item_content_index}, {byte_count} bytes"
                 )
@@ -269,9 +263,7 @@ async def _flush_audio_buffer(self) -> None:
                 self._startup_buffer.extend(buffer_data)
 
                 # target bytes = N chunks * bytes-per-chunk
-                target_bytes = self.BUFFER_SIZE_BYTES * max(
-                    0, self.STARTUP_BUFFER_CHUNKS
-                )
+                target_bytes = self.BUFFER_SIZE_BYTES * max(0, self.STARTUP_BUFFER_CHUNKS)
 
                 if len(self._startup_buffer) >= target_bytes:
                     # Warm-up complete: flush all buffered data in order
@@ -298,8 +290,7 @@ async def _buffer_flush_loop(self) -> None:
                 current_time = time.time()
                 if (
                     self._audio_buffer
-                    and current_time - self._last_buffer_send_time
-                    > self.CHUNK_LENGTH_S * 2
+                    and current_time - self._last_buffer_send_time > self.CHUNK_LENGTH_S * 2
                 ):
                     await self._flush_audio_buffer()