Verbose

shared.py

@@ -344,14 +344,13 @@ class RealtimeSpeakerDiarization:
                     min_length_of_recording=MIN_LENGTH_OF_RECORDING,
                     pre_recording_buffer_duration=PRE_RECORDING_BUFFER_DURATION,
                     enable_realtime_transcription=True,
-                    realtime_processing_pause=0,
+                    realtime_processing_pause=0.2,
                     realtime_model_type=REALTIME_TRANSCRIPTION_MODEL,
                     on_realtime_transcription_update=self.live_text_detected,
                     on_recording_stop=self.process_final_text,
-                    # Add setting to reduce log spam
-                    verbose=False,
+                    level=logging.WARNING,
                     # Don't start processing immediately
-                    start_on_init=False
+                    handle_buffer_overflow=True
                 )
                 
                 logger.info("Models initialized successfully!")

test_websocket.py

@@ -15,6 +15,7 @@ async def test_ws():
             audio = (np.random.randn(3200) * 3000).astype(np.int16)
             await websocket.send(audio.tobytes())
             print(f"Sent audio chunk {i+1}/20")
+            await asyncio.sleep(0.050)
 
         try:
             while True: