Mark Backman 47e53890e3 Fix FastAPI WebSocket disconnect race condition causing pipeline hang ...

When the remote side disconnects while send() is in flight, send() was
setting _closing=True. This prevented the receive loop from firing
on_client_disconnected, causing the pipeline to hang waiting for a
disconnect signal that never came.

The fix removes _closing from send() (that flag means we initiated the
close) and instead checks Starlette application_state in _can_send()
to suppress subsequent sends after a failure.

Fixes #3912

2026-03-28 00:01:25 -04:00

..

genesys

fix: always include parameters field in Genesys AudioHook messages

2026-03-20 16:37:53 -03:00

integration

Fix broken test_unified_function_calling_anthropic due to use of an unsupported/deprecated model.

2026-03-09 12:07:56 -04:00

__init__.py

tests: add some initial run_test() utilities

2025-01-20 17:41:21 -08:00

test_aggregators.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_aic_filter.py

update test description.

2026-03-10 14:54:49 +01:00

test_aic_vad.py

add unit tests for AICVADAnalyzer and AICFilter.

2026-01-26 09:56:36 +01:00

test_audio_buffer_processor.py

Automated tests to validate the silence injection guards.

2026-03-25 16:05:58 -03:00

test_context_aggregators_universal.py

Move turn completion instructions to system_instruction

2026-03-08 10:41:40 -04:00

test_context_aggregators.py

Add broadcast_interruption() to FrameProcessor

2026-03-02 13:26:45 -08:00

test_context_summarization.py

Remove unused imports, 2026-03-07

2026-03-09 12:44:47 -04:00

test_daily_transport_service.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_deepgram_stt.py

Add tests for send_media() exception handling in DeepgramSTTService

2026-03-26 09:20:58 -04:00

test_direct_functions.py

update examples and tests copyright and use a proper dash in 2024-2026

2026-01-07 19:32:22 -08:00

test_dtmf_aggregator.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_fastapi_websocket.py

Fix FastAPI WebSocket disconnect race condition causing pipeline hang

2026-03-28 00:01:25 -04:00

test_filters.py

Simplify ServiceSwitcher with closure-based filters

2026-02-09 14:12:33 -05:00

test_frame_processor.py

Add broadcast_interruption() to FrameProcessor

2026-03-02 13:26:45 -08:00

test_function_calling_adapters.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_get_llm_invocation_params.py

Add system instruction conflict resolution tests for realtime adapters

2026-03-24 17:30:35 -04:00

test_google_llm_openai.py

Update imports to use new google.vertex and google.openai paths

2026-03-10 12:58:04 -07:00

test_google_utils.py

update examples and tests copyright and use a proper dash in 2024-2026

2026-01-07 19:32:22 -08:00

test_interruption_strategies.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_ivr_navigation.py

Fix IVRNavigator to push AggregatedTextFrame when switching to conversation mode

2026-01-30 21:07:49 -05:00

test_krisp_sdk_manager.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_krisp_viva_filter.py

Clean up CambTTSService

2026-01-15 15:59:17 -05:00

test_krisp_viva_vad.py

Fixed review comments.

2026-03-23 17:44:48 +04:00

test_langchain.py

Fix test_langchain to use explicit stop strategy

2026-02-09 12:00:41 -08:00

test_livekit_transport.py

chore: install livekit as optional extra in CI instead of dev dep

2026-01-20 09:16:16 -05:00

test_llm_context_summarizer.py

Make max_context_tokens and max_unsummarized_messages independently optional

2026-03-03 20:08:22 -05:00

test_llm_response.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_markdown_text_filter.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_novita_llm.py

Add Novita AI LLM service provider

2026-03-24 09:20:50 -04:00

test_openai_llm_timeout.py

Fix async generator cleanup to prevent uvloop crash on Python 3.12+

2026-02-17 13:10:31 -05:00

test_pattern_pair_aggregator.py

Add text_aggregation_mode parameter to TTSService

2026-02-26 08:55:41 -05:00

test_pipeline.py

Add optional direction parameter to PipelineTask.queue_frame() and queue_frames()

2026-02-28 17:28:44 -08:00

test_piper_tts.py

Fixing Piper test.

2026-03-09 12:07:45 -03:00

test_producer_consumer.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_protobuf_serializer.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_rnnoise_cancellation.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_rnnoise_filter.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_rnnoise_resampling.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_run_inference.py

Convert developer messages to user for Cerebras (and lay groundwork for other incompatible services)

2026-03-24 16:05:15 -04:00

test_runner_utils.py

Apply suggestions from code review

2026-02-03 16:42:13 +08:00

test_sambanova_llm.py

fix: close stream on cancellation for SambaNova and Google OpenAI services

2026-02-06 10:02:40 -05:00

test_service_init.py

Address code review feedback

2026-03-07 07:42:42 -05:00

test_service_language.py

Update language tests to expect debug instead of warning

2026-03-25 10:26:10 -04:00

test_service_switcher.py

Fix ServiceSwitcher reacting to pass-through ErrorFrames from other pipeline stages

2026-03-25 22:53:04 -04:00

test_settings.py

Consolidate Grok services into xai module

2026-03-25 12:07:40 -04:00

test_simple_text_aggregator.py

Add text_aggregation_mode parameter to TTSService

2026-02-26 08:55:41 -05:00

test_skip_tags_aggregator.py

Add text_aggregation_mode parameter to TTSService

2026-02-26 08:55:41 -05:00

test_startup_timing_observer.py

Replace per-processor start_time with start_offset_secs

2026-03-02 14:07:34 -05:00

test_stt_mute_filter.py

Add broadcast_interruption() to FrameProcessor

2026-03-02 13:26:45 -08:00

test_sync_parallel_pipeline.py

Add frame_order parameter to SyncParallelPipeline

2026-03-19 09:43:51 -04:00

test_tracing_context.py

Add tests for TracingContext and TurnTraceObserver

2026-02-11 23:27:35 -05:00

test_transcript_processor.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_tts_frame_ordering.py

Fix LLMFullResponseEndFrame racing ahead of final TTSTextFrame

2026-03-24 15:09:42 -04:00

test_turn_trace_observer.py

Add tests for TracingContext and TurnTraceObserver

2026-02-11 23:27:35 -05:00

test_turn_tracking_observer.py

update examples and tests copyright and use a proper dash in 2024-2026

2026-01-07 19:32:22 -08:00

test_user_bot_latency_observer.py

Add chronological_events utility function to display UserBotLatencyObserver report

2026-03-02 19:23:42 -05:00

test_user_idle_controller.py

Make UserIdleController always-on with dynamic timeout updates

2026-02-14 09:54:30 -05:00

test_user_idle_processor.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_user_mute_strategy.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_user_turn_completion_mixin.py

Move turn completion instructions to system_instruction

2026-03-08 10:41:40 -04:00

test_user_turn_controller.py

Fix stale state in user turn stop strategies between turns

2026-03-17 11:31:08 -04:00

test_user_turn_processor.py

Improve user turn stop timing by triggering timeout from VAD stop

2026-02-09 14:12:33 -05:00

test_user_turn_start_strategy.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_user_turn_stop_strategy.py

Warn when VAD stop_secs misconfiguration may degrade turn detection

2026-03-23 17:57:51 -04:00

test_utils_network.py

tests: add unittest.main() call

2026-01-30 10:07:34 -08:00

test_utils_string.py

Fix sentence splitting for CJK and other non-Latin languages in TTS pipeline

2026-02-02 14:27:49 +08:00

test_vad_controller.py

Fix: Broadcast SpeechControlParamsFrame from VADController

2026-02-03 18:40:39 -05:00

test_vad_processor.py

Fix: Broadcast SpeechControlParamsFrame from VADController

2026-02-03 18:40:39 -05:00

test_wake_phrase_user_turn_start_strategy.py

Add WakePhraseUserTurnStartStrategy (#4064)

2026-03-18 16:47:17 -04:00

test_websocket_transport.py

update examples and tests copyright and use a proper dash in 2024-2026

2026-01-07 19:32:22 -08:00

test_xai_tts.py

Address PR review: rename to XAIHttpTTSService, add language map, clean up API

2026-03-25 10:46:54 -04:00