AudioBufferProcessor: record with lowest sample rate

Fixes #1653
Merge pull request #2027 from pipecat-ai/aleix/task-on-idle-timeout-repeated
2025-06-19 14:18:54 -07:00 · 2025-06-19 14:13:10 -07:00 · 2025-06-19 09:14:10 -07:00 · 2025-06-19 10:24:53 -04:00 · 2025-06-19 10:07:32 -04:00 · 2025-06-18 18:26:38 -07:00
184 changed files with 3492 additions and 684 deletions
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -5,7 +5,80 @@ All notable changes to **Pipecat** will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).

-## [0.0.70]
+## [Unreleased]
+
+### Added
+
+- Added reconnection logic and audio buffer management to `GladiaSTTService`.
+
+- Added Polish support to `AWSTranscribeSTTService`.
+
+- Added new frames `FrameProcessorPauseFrame` and `FrameProcessorResumeFrame`
+  which allow pausing and resuming frame processing for a given frame
+  processor. These are control frames, so they are ordered. Pausing frame
+  processor will keep old frames in the internal queues until resume takes
+  place. Frames being pushed while a frame processor is paused will be pushed to
+  the queues. When frame processing is resumed all queued frames will be
+  processed in order. Also added `FrameProcessorPauseUrgentFrame` and
+  `FrameProcessorResumeUrgentFrame` which are system frames and therefore they
+  have high priority.
+
+- Added a property called `has_function_calls_in_progress` in
+  `LLMAssistantContextAggregator` that exposes whether a function call is in
+  progress.
+
+### Changed
+
+- The `PipelineParams` arg `allow_interruptions` now defaults to `True`.
+
+- `TavusTransport` and `TavusVideoService` now send audio to Tavus using WebRTC
+  audio tracks instead of `app-messages` over WebSocket. This should improve the
+  overall audio quality.
+
+- Upgraded `daily-python` to 0.19.3.
+
+### Deprecated
+
+- `AudioBufferProcessor` parameter `user_continuos_stream` is deprecated.
+
+### Fixed
+
+- Fixed an `AudioBufferProcessor` issue that was causing crackling on the audio
+  stream with lower sample rate (due to upsampling the other stream). We now
+  record with the lowest sample rate to avoid upsampling.
+
+- Fixed an issue that would cause multiple `PipelineTask.on_idle_timeout`
+  events to be triggered repeatedly.
+
+- Fixed an `AudioBufferProcessor` issue that was causing user and bot speech to
+  not be synchronized during recordings.
+
+- Fixed an issue where voice settings weren't applied to ElevenLabsTTSService.
+
+- Fixed an issue with `GroqTTSService` where it was not properly parsing the
+  WAV file header.
+
+- Fixed an issue with `GoogleSTTService` where it was constantly reconnecting
+  before starting to receive audio from the user.
+
+- Fixed an issue where `GoogleLLMService`'s TTFB value was incorrect.
+
+### Other
+
+- Rename `14e-function-calling-gemini.py` to `14e-function-calling-google.py`.
+
+## [0.0.71] - 2025-06-10
+
+### Added
+
+- Adds a parameter called `additional_span_attributes` to PipelineTask that
+  lets you add any additional attributes you'd like to the conversation span.
+
+### Fixed
+
+- Fixed an issue with `CartesiaSTTService` initialization.
+
+## [0.0.70] - 2025-06-10

 ### Added

--- a/README.md
+++ b/README.md
@@ -53,7 +53,7 @@ You can connect to Pipecat from any platform using our official SDKs:

 | Category            | Services                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  |
 | ------------------- | --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- |
-| Speech-to-Text      | [AssemblyAI](https://docs.pipecat.ai/server/services/stt/assemblyai), [AWS](https://docs.pipecat.ai/server/services/stt/aws), [Azure](https://docs.pipecat.ai/server/services/stt/azure), Cartesia, [Deepgram](https://docs.pipecat.ai/server/services/stt/deepgram), [Fal Wizper](https://docs.pipecat.ai/server/services/stt/fal), [Gladia](https://docs.pipecat.ai/server/services/stt/gladia), [Google](https://docs.pipecat.ai/server/services/stt/google), [Groq (Whisper)](https://docs.pipecat.ai/server/services/stt/groq), [OpenAI (Whisper)](https://docs.pipecat.ai/server/services/stt/openai), [Parakeet (NVIDIA)](https://docs.pipecat.ai/server/services/stt/parakeet), [Ultravox](https://docs.pipecat.ai/server/services/stt/ultravox), [Whisper](https://docs.pipecat.ai/server/services/stt/whisper)                                                                                                                                                                                                                                                                                            |
+| Speech-to-Text      | [AssemblyAI](https://docs.pipecat.ai/server/services/stt/assemblyai), [AWS](https://docs.pipecat.ai/server/services/stt/aws), [Azure](https://docs.pipecat.ai/server/services/stt/azure), [Cartesia](https://docs.pipecat.ai/server/services/stt/cartesia), [Deepgram](https://docs.pipecat.ai/server/services/stt/deepgram), [Fal Wizper](https://docs.pipecat.ai/server/services/stt/fal), [Gladia](https://docs.pipecat.ai/server/services/stt/gladia), [Google](https://docs.pipecat.ai/server/services/stt/google), [Groq (Whisper)](https://docs.pipecat.ai/server/services/stt/groq), [OpenAI (Whisper)](https://docs.pipecat.ai/server/services/stt/openai), [Parakeet (NVIDIA)](https://docs.pipecat.ai/server/services/stt/parakeet), [Ultravox](https://docs.pipecat.ai/server/services/stt/ultravox), [Whisper](https://docs.pipecat.ai/server/services/stt/whisper)                                                                                                                                                                                                                          |
 | LLMs                | [Anthropic](https://docs.pipecat.ai/server/services/llm/anthropic), [AWS](https://docs.pipecat.ai/server/services/llm/aws), [Azure](https://docs.pipecat.ai/server/services/llm/azure), [Cerebras](https://docs.pipecat.ai/server/services/llm/cerebras), [DeepSeek](https://docs.pipecat.ai/server/services/llm/deepseek), [Fireworks AI](https://docs.pipecat.ai/server/services/llm/fireworks), [Gemini](https://docs.pipecat.ai/server/services/llm/gemini), [Grok](https://docs.pipecat.ai/server/services/llm/grok), [Groq](https://docs.pipecat.ai/server/services/llm/groq), [NVIDIA NIM](https://docs.pipecat.ai/server/services/llm/nim), [Ollama](https://docs.pipecat.ai/server/services/llm/ollama), [OpenAI](https://docs.pipecat.ai/server/services/llm/openai), [OpenRouter](https://docs.pipecat.ai/server/services/llm/openrouter), [Perplexity](https://docs.pipecat.ai/server/services/llm/perplexity), [Qwen](https://docs.pipecat.ai/server/services/llm/qwen), [Together AI](https://docs.pipecat.ai/server/services/llm/together)                                                 |
 | Text-to-Speech      | [AWS](https://docs.pipecat.ai/server/services/tts/aws), [Azure](https://docs.pipecat.ai/server/services/tts/azure), [Cartesia](https://docs.pipecat.ai/server/services/tts/cartesia), [Deepgram](https://docs.pipecat.ai/server/services/tts/deepgram), [ElevenLabs](https://docs.pipecat.ai/server/services/tts/elevenlabs), [FastPitch (NVIDIA)](https://docs.pipecat.ai/server/services/tts/fastpitch), [Fish](https://docs.pipecat.ai/server/services/tts/fish), [Google](https://docs.pipecat.ai/server/services/tts/google), [LMNT](https://docs.pipecat.ai/server/services/tts/lmnt), [MiniMax](https://docs.pipecat.ai/server/services/tts/minimax), [Neuphonic](https://docs.pipecat.ai/server/services/tts/neuphonic), [OpenAI](https://docs.pipecat.ai/server/services/tts/openai), [Piper](https://docs.pipecat.ai/server/services/tts/piper), [PlayHT](https://docs.pipecat.ai/server/services/tts/playht), [Rime](https://docs.pipecat.ai/server/services/tts/rime), [Sarvam](https://docs.pipecat.ai/server/services/tts/sarvam), [XTTS](https://docs.pipecat.ai/server/services/tts/xtts) |
 | Speech-to-Speech    | [AWS Nova Sonic](https://docs.pipecat.ai/server/services/s2s/aws), [Gemini Multimodal Live](https://docs.pipecat.ai/server/services/s2s/gemini), [OpenAI Realtime](https://docs.pipecat.ai/server/services/s2s/openai)                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    |
--- a/dev-requirements.txt
+++ b/dev-requirements.txt
@@ -3,11 +3,11 @@ coverage~=7.6.12
 grpcio-tools~=1.67.1
 pip-tools~=7.4.1
 pre-commit~=4.0.1
-pyright~=1.1.397
+pyright~=1.1.400
 pytest~=8.3.4
 pytest-asyncio~=0.25.3
 pytest-aiohttp==1.1.0
-ruff~=0.11.1
+ruff~=0.11.13
 setuptools~=70.0.0
 setuptools_scm~=8.1.0
 python-dotenv~=1.0.1
--- a/examples/chatbot-audio-recording/bot.py
+++ b/examples/chatbot-audio-recording/bot.py
@@ -133,7 +133,8 @@ async def main():
            params=PipelineParams(
                audio_in_sample_rate=16000,
                audio_out_sample_rate=16000,
-                allow_interruptions=True,
+                enable_metrics=True,
+                enable_usage_metrics=True,
            ),
        )

--- a/examples/daily-custom-tracks/bot.py
+++ b/examples/daily-custom-tracks/bot.py
@@ -71,6 +71,8 @@ async def main():
            params=PipelineParams(
                audio_in_sample_rate=16000,
                audio_out_sample_rate=16000,
+                enable_metrics=True,
+                enable_usage_metrics=True,
            ),
        )

--- a/examples/daily-multi-translation/bot.py
+++ b/examples/daily-multi-translation/bot.py
@@ -148,10 +148,8 @@ async def main():
            params=PipelineParams(
                audio_in_sample_rate=16000,
                audio_out_sample_rate=16000,
-                allow_interruptions=True,
                enable_metrics=True,
                enable_usage_metrics=True,
-                report_only_initial_ttfb=True,
            ),
            observers=[TranscriptionLogObserver()],
        )
--- a/examples/deployment/flyio-example/bot.py
+++ b/examples/deployment/flyio-example/bot.py
@@ -75,7 +75,13 @@ async def main(room_url: str, token: str):
        ]
    )

-    task = PipelineTask(pipeline, params=PipelineParams(allow_interruptions=True))
+    task = PipelineTask(
+        pipeline,
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
+    )

    @transport.event_handler("on_first_participant_joined")
    async def on_first_participant_joined(transport, participant):
--- a/examples/deployment/modal-example/server/src/bot_gemini.py
+++ b/examples/deployment/modal-example/server/src/bot_gemini.py
@@ -170,7 +170,6 @@ async def run_bot(room_url: str, token: str):
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/deployment/modal-example/server/src/bot_openai.py
+++ b/examples/deployment/modal-example/server/src/bot_openai.py
@@ -198,7 +198,6 @@ async def run_bot(room_url: str, token: str):
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/deployment/modal-example/server/src/bot_vllm.py
+++ b/examples/deployment/modal-example/server/src/bot_vllm.py
@@ -211,7 +211,6 @@ async def run_bot(room_url: str, token: str):
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/deployment/pipecat-cloud-example/bot.py
+++ b/examples/deployment/pipecat-cloud-example/bot.py
@@ -67,10 +67,8 @@ async def main(transport: DailyTransport):
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/fal-smart-turn/server/bot.py
+++ b/examples/fal-smart-turn/server/bot.py
@@ -192,7 +192,6 @@ async def main(transport: DailyTransport):
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/03b-still-frame-imagen.py
+++ b/examples/foundational/03b-still-frame-imagen.py
@@ -47,7 +47,10 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si

    task = PipelineTask(
        Pipeline([imagegen, transport.output()]),
-        params=PipelineParams(enable_metrics=True),
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
    )

    # Register an event handler so we can play the audio when the client joins
--- a/examples/foundational/04-transports-small-webrtc.py
+++ b/examples/foundational/04-transports-small-webrtc.py
@@ -93,10 +93,8 @@ async def run_example(webrtc_connection: SmallWebRTCConnection):
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/04a-transports-daily.py
+++ b/examples/foundational/04a-transports-daily.py
@@ -75,10 +75,8 @@ async def main():
        task = PipelineTask(
            pipeline,
            params=PipelineParams(
-                allow_interruptions=True,
                enable_metrics=True,
                enable_usage_metrics=True,
-                report_only_initial_ttfb=True,
            ),
        )

--- a/examples/foundational/04b-transports-livekit.py
+++ b/examples/foundational/04b-transports-livekit.py
@@ -158,7 +158,8 @@ async def main():
            ],
        ),
        params=PipelineParams(
-            allow_interruptions=True, enable_metrics=True, enable_usage_metrics=True
+            enable_metrics=True,
+            enable_usage_metrics=True,
        ),
    )

--- a/examples/foundational/06a-image-sync.py
+++ b/examples/foundational/06a-image-sync.py
@@ -133,10 +133,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07-interruptible-cartesia-http.py
+++ b/examples/foundational/07-interruptible-cartesia-http.py
@@ -84,10 +84,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07-interruptible.py
+++ b/examples/foundational/07-interruptible.py
@@ -83,10 +83,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07b-interruptible-langchain.py
+++ b/examples/foundational/07b-interruptible-langchain.py
@@ -113,10 +113,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07c-interruptible-deepgram-vad.py
+++ b/examples/foundational/07c-interruptible-deepgram-vad.py
@@ -87,10 +87,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07c-interruptible-deepgram.py
+++ b/examples/foundational/07c-interruptible-deepgram.py
@@ -81,10 +81,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07d-interruptible-elevenlabs-http.py
+++ b/examples/foundational/07d-interruptible-elevenlabs-http.py
@@ -88,10 +88,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
        task = PipelineTask(
            pipeline,
            params=PipelineParams(
-                allow_interruptions=True,
                enable_metrics=True,
                enable_usage_metrics=True,
-                report_only_initial_ttfb=True,
            ),
        )

--- a/examples/foundational/07d-interruptible-elevenlabs.py
+++ b/examples/foundational/07d-interruptible-elevenlabs.py
@@ -84,10 +84,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07e-interruptible-playht-http.py
+++ b/examples/foundational/07e-interruptible-playht-http.py
@@ -84,10 +84,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07e-interruptible-playht.py
+++ b/examples/foundational/07e-interruptible-playht.py
@@ -86,10 +86,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07f-interruptible-azure.py
+++ b/examples/foundational/07f-interruptible-azure.py
@@ -90,10 +90,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07g-interruptible-openai.py
+++ b/examples/foundational/07g-interruptible-openai.py
@@ -84,11 +84,9 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            audio_out_sample_rate=24000,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07h-interruptible-openpipe.py
+++ b/examples/foundational/07h-interruptible-openpipe.py
@@ -89,10 +89,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07i-interruptible-xtts.py
+++ b/examples/foundational/07i-interruptible-xtts.py
@@ -87,10 +87,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
        task = PipelineTask(
            pipeline,
            params=PipelineParams(
-                allow_interruptions=True,
                enable_metrics=True,
                enable_usage_metrics=True,
-                report_only_initial_ttfb=True,
            ),
        )

--- a/examples/foundational/07j-interruptible-gladia.py
+++ b/examples/foundational/07j-interruptible-gladia.py
@@ -92,10 +92,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07k-interruptible-lmnt.py
+++ b/examples/foundational/07k-interruptible-lmnt.py
@@ -80,10 +80,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07l-interruptible-groq.py
+++ b/examples/foundational/07l-interruptible-groq.py
@@ -85,7 +85,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/07m-interruptible-aws.py
+++ b/examples/foundational/07m-interruptible-aws.py
@@ -87,10 +87,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07n-interruptible-google.py
+++ b/examples/foundational/07n-interruptible-google.py
@@ -88,10 +88,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07o-interruptible-assemblyai.py
+++ b/examples/foundational/07o-interruptible-assemblyai.py
@@ -86,10 +86,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07p-interruptible-krisp.py
+++ b/examples/foundational/07p-interruptible-krisp.py
@@ -84,10 +84,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07q-interruptible-rime-http.py
+++ b/examples/foundational/07q-interruptible-rime-http.py
@@ -89,10 +89,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
        task = PipelineTask(
            pipeline,
            params=PipelineParams(
-                allow_interruptions=True,
                enable_metrics=True,
                enable_usage_metrics=True,
-                report_only_initial_ttfb=True,
            ),
        )

--- a/examples/foundational/07q-interruptible-rime.py
+++ b/examples/foundational/07q-interruptible-rime.py
@@ -83,10 +83,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07r-interruptible-riva-nim.py
+++ b/examples/foundational/07r-interruptible-riva-nim.py
@@ -80,10 +80,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07s-interruptible-google-audio-in.py
+++ b/examples/foundational/07s-interruptible-google-audio-in.py
@@ -258,7 +258,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/07t-interruptible-fish.py
+++ b/examples/foundational/07t-interruptible-fish.py
@@ -84,10 +84,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07u-interruptible-ultravox.py
+++ b/examples/foundational/07u-interruptible-ultravox.py
@@ -77,8 +77,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
+            enable_usage_metrics=True,
        ),
    )

--- a/examples/foundational/07v-interruptible-neuphonic-http.py
+++ b/examples/foundational/07v-interruptible-neuphonic-http.py
@@ -84,10 +84,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07v-interruptible-neuphonic.py
+++ b/examples/foundational/07v-interruptible-neuphonic.py
@@ -83,10 +83,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07w-interruptible-fal.py
+++ b/examples/foundational/07w-interruptible-fal.py
@@ -86,10 +86,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07x-interruptible-local.py
+++ b/examples/foundational/07x-interruptible-local.py
@@ -70,10 +70,8 @@ async def main():
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/07y-interruptible-minimax.py
+++ b/examples/foundational/07y-interruptible-minimax.py
@@ -90,10 +90,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
        task = PipelineTask(
            pipeline,
            params=PipelineParams(
-                allow_interruptions=True,
                enable_metrics=True,
                enable_usage_metrics=True,
-                report_only_initial_ttfb=True,
            ),
        )

--- a/examples/foundational/07z-interruptible-sarvam.py
+++ b/examples/foundational/07z-interruptible-sarvam.py
@@ -89,10 +89,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
        task = PipelineTask(
            pipeline,
            params=PipelineParams(
-                allow_interruptions=True,
                enable_metrics=True,
                enable_usage_metrics=True,
-                report_only_initial_ttfb=True,
            ),
        )

--- a/examples/foundational/10-wake-phrase.py
+++ b/examples/foundational/10-wake-phrase.py
@@ -85,7 +85,13 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
        ]
    )

-    task = PipelineTask(pipeline, params=PipelineParams(allow_interruptions=True))
+    task = PipelineTask(
+        pipeline,
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
+    )

    @transport.event_handler("on_client_connected")
    async def on_client_connected(transport, client):
--- a/examples/foundational/12a-describe-video-gemini-flash.py
+++ b/examples/foundational/12a-describe-video-gemini-flash.py
@@ -101,7 +101,10 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si

    task = PipelineTask(
        pipeline,
-        params=PipelineParams(allow_interruptions=True),
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
    )

    @transport.event_handler("on_client_connected")
--- a/examples/foundational/12b-describe-video-gpt-4o.py
+++ b/examples/foundational/12b-describe-video-gpt-4o.py
@@ -101,7 +101,10 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si

    task = PipelineTask(
        pipeline,
-        params=PipelineParams(allow_interruptions=True),
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
    )

    @transport.event_handler("on_client_connected")
--- a/examples/foundational/12c-describe-video-anthropic.py
+++ b/examples/foundational/12c-describe-video-anthropic.py
@@ -101,7 +101,10 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si

    task = PipelineTask(
        pipeline,
-        params=PipelineParams(allow_interruptions=True),
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
    )

    @transport.event_handler("on_client_connected")
--- a/examples/foundational/13e-whisper-mlx.py
+++ b/examples/foundational/13e-whisper-mlx.py
@@ -84,7 +84,7 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
        pipeline,
        params=PipelineParams(
            enable_metrics=True,
-            report_only_initial_ttfb=False,
+            enable_usage_metrics=True,
        ),
    )

--- a/examples/foundational/14-function-calling.py
+++ b/examples/foundational/14-function-calling.py
@@ -134,10 +134,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/14a-function-calling-anthropic.py
+++ b/examples/foundational/14a-function-calling-anthropic.py
@@ -127,8 +127,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
+            enable_usage_metrics=True,
        ),
    )

--- a/examples/foundational/14b-function-calling-anthropic-video.py
+++ b/examples/foundational/14b-function-calling-anthropic-video.py
@@ -172,8 +172,8 @@ If you need to use a tool, simply use the tool. Do not tell the user the tool yo
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
+            enable_usage_metrics=True,
        ),
    )

--- a/examples/foundational/14c-function-calling-together.py
+++ b/examples/foundational/14c-function-calling-together.py
@@ -16,7 +16,7 @@ from pipecat.audio.vad.silero import SileroVADAnalyzer
 from pipecat.frames.frames import TTSSpeakFrame
 from pipecat.pipeline.pipeline import Pipeline
 from pipecat.pipeline.runner import PipelineRunner
-from pipecat.pipeline.task import PipelineTask
+from pipecat.pipeline.task import PipelineParams, PipelineTask
 from pipecat.processors.aggregators.openai_llm_context import OpenAILLMContext
 from pipecat.services.cartesia.tts import CartesiaTTSService
 from pipecat.services.deepgram.stt import DeepgramSTTService
@@ -116,7 +116,13 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
        ]
    )

-    task = PipelineTask(pipeline)
+    task = PipelineTask(
+        pipeline,
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
+    )

    @transport.event_handler("on_client_connected")
    async def on_client_connected(transport, client):
--- a/examples/foundational/14d-function-calling-video.py
+++ b/examples/foundational/14d-function-calling-video.py
@@ -17,7 +17,7 @@ from pipecat.audio.vad.silero import SileroVADAnalyzer
 from pipecat.examples.run import get_transport_client_id, maybe_capture_participant_camera
 from pipecat.pipeline.pipeline import Pipeline
 from pipecat.pipeline.runner import PipelineRunner
-from pipecat.pipeline.task import PipelineTask
+from pipecat.pipeline.task import PipelineParams, PipelineTask
 from pipecat.processors.aggregators.openai_llm_context import OpenAILLMContext
 from pipecat.services.cartesia.tts import CartesiaTTSService
 from pipecat.services.deepgram.stt import DeepgramSTTService
@@ -158,7 +158,13 @@ indicate you should use the get_image tool are:
        ]
    )

-    task = PipelineTask(pipeline)
+    task = PipelineTask(
+        pipeline,
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
+    )

    @transport.event_handler("on_client_connected")
    async def on_client_connected(transport, client):
--- a/examples/foundational/14e-function-calling-google.py
+++ b/examples/foundational/14e-function-calling-google.py
@@ -183,7 +183,6 @@ indicate you should use the get_image tool are:
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/14f-function-calling-groq.py
+++ b/examples/foundational/14f-function-calling-groq.py
@@ -121,7 +121,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/14g-function-calling-grok.py
+++ b/examples/foundational/14g-function-calling-grok.py
@@ -111,7 +111,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/14h-function-calling-azure.py
+++ b/examples/foundational/14h-function-calling-azure.py
@@ -120,7 +120,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/14i-function-calling-fireworks.py
+++ b/examples/foundational/14i-function-calling-fireworks.py
@@ -119,7 +119,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/14j-function-calling-nim.py
+++ b/examples/foundational/14j-function-calling-nim.py
@@ -117,7 +117,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/14k-function-calling-cerebras.py
+++ b/examples/foundational/14k-function-calling-cerebras.py
@@ -126,10 +126,8 @@ Start by asking me for my location. Then, use 'get_weather_current' to give me a
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/14l-function-calling-deepseek.py
+++ b/examples/foundational/14l-function-calling-deepseek.py
@@ -126,10 +126,8 @@ Start by asking me for my location. Then, use 'get_weather_current' to give me a
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/14m-function-calling-openrouter.py
+++ b/examples/foundational/14m-function-calling-openrouter.py
@@ -120,10 +120,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/14n-function-calling-perplexity.py
+++ b/examples/foundational/14n-function-calling-perplexity.py
@@ -90,10 +90,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/14o-function-calling-gemini-openai-format.py
+++ b/examples/foundational/14o-function-calling-gemini-openai-format.py
@@ -116,7 +116,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/14p-function-calling-gemini-vertex-ai.py
+++ b/examples/foundational/14p-function-calling-gemini-vertex-ai.py
@@ -122,7 +122,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/14q-function-calling-qwen.py
+++ b/examples/foundational/14q-function-calling-qwen.py
@@ -118,10 +118,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/14r-function-calling-aws.py
+++ b/examples/foundational/14r-function-calling-aws.py
@@ -134,10 +134,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/15-switch-voices.py
+++ b/examples/foundational/15-switch-voices.py
@@ -147,7 +147,13 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
        ]
    )

-    task = PipelineTask(pipeline, params=PipelineParams(allow_interruptions=True))
+    task = PipelineTask(
+        pipeline,
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
+    )

    @transport.event_handler("on_client_connected")
    async def on_client_connected(transport, client):
--- a/examples/foundational/15a-switch-languages.py
+++ b/examples/foundational/15a-switch-languages.py
@@ -135,7 +135,13 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
        ]
    )

-    task = PipelineTask(pipeline, params=PipelineParams(allow_interruptions=True))
+    task = PipelineTask(
+        pipeline,
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
+    )

    @transport.event_handler("on_client_connected")
    async def on_client_connected(transport, client):
--- a/examples/foundational/16-gpu-container-local-bot.py
+++ b/examples/foundational/16-gpu-container-local-bot.py
@@ -90,8 +90,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
+            enable_usage_metrics=True,
        ),
    )

--- a/examples/foundational/17-detect-user-idle.py
+++ b/examples/foundational/17-detect-user-idle.py
@@ -117,9 +117,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
-            report_only_initial_ttfb=True,
+            enable_usage_metrics=True,
        ),
    )

--- a/examples/foundational/19-openai-realtime-beta.py
+++ b/examples/foundational/19-openai-realtime-beta.py
@@ -186,10 +186,8 @@ Remember, your responses should be short. Just one or two sentences, usually."""
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/19a-azure-realtime-beta.py
+++ b/examples/foundational/19a-azure-realtime-beta.py
@@ -179,10 +179,8 @@ Remember, your responses should be short. Just one or two sentences, usually."""
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/20a-persistent-context-openai.py
+++ b/examples/foundational/20a-persistent-context-openai.py
@@ -223,10 +223,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/20b-persistent-context-openai-realtime.py
+++ b/examples/foundational/20b-persistent-context-openai-realtime.py
@@ -233,10 +233,8 @@ Remember, your responses should be short. Just one or two sentences, usually."""
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/20c-persistent-context-anthropic.py
+++ b/examples/foundational/20c-persistent-context-anthropic.py
@@ -222,10 +222,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            # report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/20d-persistent-context-gemini.py
+++ b/examples/foundational/20d-persistent-context-gemini.py
@@ -275,10 +275,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            # report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/20e-persistent-context-aws-nova-sonic.py
+++ b/examples/foundational/20e-persistent-context-aws-nova-sonic.py
@@ -242,10 +242,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/21-tavus-transport.py
+++ b/examples/foundational/21-tavus-transport.py
@@ -79,10 +79,8 @@ async def main():
            params=PipelineParams(
                audio_in_sample_rate=16000,
                audio_out_sample_rate=24000,
-                allow_interruptions=True,
                enable_metrics=True,
                enable_usage_metrics=True,
-                report_only_initial_ttfb=True,
            ),
        )

--- a/examples/foundational/21a-tavus-video-service.py
+++ b/examples/foundational/21a-tavus-video-service.py
@@ -96,10 +96,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
            params=PipelineParams(
                audio_in_sample_rate=16000,
                audio_out_sample_rate=24000,
-                allow_interruptions=True,
                enable_metrics=True,
                enable_usage_metrics=True,
-                report_only_initial_ttfb=True,
            ),
        )

--- a/examples/foundational/22-natural-conversation.py
+++ b/examples/foundational/22-natural-conversation.py
@@ -147,10 +147,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/22b-natural-conversation-proposal.py
+++ b/examples/foundational/22b-natural-conversation-proposal.py
@@ -353,10 +353,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/22c-natural-conversation-mixed-llms.py
+++ b/examples/foundational/22c-natural-conversation-mixed-llms.py
@@ -564,7 +564,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/22d-natural-conversation-gemini-audio.py
+++ b/examples/foundational/22d-natural-conversation-gemini-audio.py
@@ -746,7 +746,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/23-bot-background-sound.py
+++ b/examples/foundational/23-bot-background-sound.py
@@ -103,10 +103,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
-            report_only_initial_ttfb=True,
        ),
    )

--- a/examples/foundational/24-stt-mute-filter.py
+++ b/examples/foundational/24-stt-mute-filter.py
@@ -121,7 +121,13 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
        ]
    )

-    task = PipelineTask(pipeline, params=PipelineParams(allow_interruptions=True))
+    task = PipelineTask(
+        pipeline,
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
+    )

    @transport.event_handler("on_client_connected")
    async def on_client_connected(transport, client):
--- a/examples/foundational/25-google-audio-in.py
+++ b/examples/foundational/25-google-audio-in.py
@@ -357,7 +357,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/26-gemini-multimodal-live.py
+++ b/examples/foundational/26-gemini-multimodal-live.py
@@ -83,7 +83,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/26a-gemini-multimodal-live-transcription.py
+++ b/examples/foundational/26a-gemini-multimodal-live-transcription.py
@@ -107,7 +107,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/26b-gemini-multimodal-live-function-calling.py
+++ b/examples/foundational/26b-gemini-multimodal-live-function-calling.py
@@ -151,7 +151,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/26c-gemini-multimodal-live-video.py
+++ b/examples/foundational/26c-gemini-multimodal-live-video.py
@@ -82,7 +82,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/26d-gemini-multimodal-live-text.py
+++ b/examples/foundational/26d-gemini-multimodal-live-text.py
@@ -119,7 +119,6 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
            enable_usage_metrics=True,
        ),
--- a/examples/foundational/26e-gemini-multimodal-google-search.py
+++ b/examples/foundational/26e-gemini-multimodal-google-search.py
@@ -107,7 +107,13 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
        ]
    )

-    task = PipelineTask(pipeline, params=PipelineParams(allow_interruptions=True))
+    task = PipelineTask(
+        pipeline,
+        params=PipelineParams(
+            enable_metrics=True,
+            enable_usage_metrics=True,
+        ),
+    )

    @transport.event_handler("on_client_connected")
    async def on_client_connected(transport, client):
--- a/examples/foundational/27-simli-layer.py
+++ b/examples/foundational/27-simli-layer.py
@@ -92,8 +92,8 @@ async def run_example(transport: BaseTransport, _: argparse.Namespace, handle_si
    task = PipelineTask(
        pipeline,
        params=PipelineParams(
-            allow_interruptions=True,
            enable_metrics=True,
+            enable_usage_metrics=True,
        ),
    )

--- a/Show More
+++ b/Show More
Author	SHA1	Message	Date
Aleix Conchillo Flaqué	5a682f8c1f	AudioBufferProcessor: record with lowest sample rate Fixes #1653	2025-06-19 14:18:54 -07:00
Aleix Conchillo Flaqué	d34ebfc126	Merge pull request #2027 from pipecat-ai/aleix/task-on-idle-timeout-repeated PipelineTask: fix repeated on_idle_timeout	2025-06-19 14:13:10 -07:00
Aleix Conchillo Flaqué	028f7b2d65	PipelineTask: fix repeated on_idle_timeout	2025-06-19 09:14:10 -07:00
Mark Backman	0aa3ec50f2	Merge pull request #2023 from pipecat-ai/mb/allow-interruptions-true allow_interruptions=True	2025-06-19 10:24:53 -04:00
Mark Backman	9146def21b	Update examples to use default allow_interruptions, fixes to align examples	2025-06-19 10:07:32 -04:00
Aleix Conchillo Flaqué	ebb23a5a8c	Merge pull request #2024 from pipecat-ai/aleix/audio-buffer-processor-sync-issues AudioBufferProcessor: treat all streams as intermittent	2025-06-18 18:26:38 -07:00
Aleix Conchillo Flaqué	b118082984	AudioBufferProcessor: treat all streams as intermittent This fixes an issue with STTMuteFilter that prevents user audio to be pushed downstream.	2025-06-18 18:23:31 -07:00
Mark Backman	b5c0ac5f25	allow_interruptions=True	2025-06-18 20:33:40 -04:00
Filipi da Silva Fuchter	dc78e874af	Merge pull request #2021 from pipecat-ai/gladia_stt_improvements_changelog Adding the GladiaSTTService improvements in the changelog.	2025-06-18 18:25:36 -03:00
Filipi Fuchter	c30bde0a2b	Adding the GladiaSTTService improvements in the changelog.	2025-06-18 16:19:58 -03:00
Filipi da Silva Fuchter	171597fbe9	Merge pull request #1952 from jqueguiner/feat/gladia-auto-reconnect feat: Enhance GladiaSTTService with reconnection and audio buffer management features	2025-06-18 16:14:58 -03:00
Mark Backman	f5d028f3b3	Merge pull request #2017 from pipecat-ai/mb/fix-11labs-voice-settings fix: ElevenLabsTTSService voice settings not being sent	2025-06-18 09:56:46 -04:00
Mark Backman	e5b7dbba90	fix: ElevenLabsTTSService voice settings not being sent	2025-06-18 09:49:17 -04:00
Filipi da Silva Fuchter	7ffba1e0b3	Merge pull request #1950 from pipecat-ai/filipi/tavus_custom_tracks Sending audio to Tavus using custom tracks	2025-06-18 07:57:19 -03:00
Filipi Fuchter	72cdbf0b78	Mentioning the Tavus improvements in the changelog.	2025-06-18 07:46:04 -03:00
Filipi Fuchter	8b4a86f629	Ignoring the audio level when creating the custom tracks.	2025-06-18 07:45:54 -03:00
Filipi Fuchter	fa15e64fc9	Test script that mimics the behavior expected to be supported by Tavus.	2025-06-18 07:45:38 -03:00
Filipi Fuchter	564f064c71	Refactoring TavusVideoService to send audio using WebRTC audio tracks instead of app-messages.	2025-06-18 07:44:51 -03:00
Filipi Fuchter	4062c7afa0	Refactoring TavusTransport to send audio using WebRTC audio tracks instead of app-messages.	2025-06-18 07:44:38 -03:00
Jean-Louis Queguiner	8071c4ba1c	Merge branch 'main' into feat/gladia-auto-reconnect	2025-06-18 08:57:21 +02:00
jqueguiner	3d0ffbc832	🐛 (stt.py): handle websocket connection closure gracefully and log warnings ♻️ (stt.py): refactor reconnection logic into a separate method for clarity ✨ (stt.py): implement exponential backoff for reconnection attempts to improve reliability	2025-06-18 08:52:43 +02:00
Filipi da Silva Fuchter	1cac94bf97	Merge pull request #1925 from pipecat-ai/filipi/websocket_transport_example_twilio Websocket client web app to test Twilio.	2025-06-17 16:24:18 -03:00
Mark Backman	96958933af	Merge pull request #2016 from pipecat-ai/aleix/example-params-allow-async-objects examples: create transport params async	2025-06-17 15:08:37 -04:00
Filipi Fuchter	2300c2632e	Refactoring how we are organizing the twilio chatbot examples and improving the readmes	2025-06-17 16:08:35 -03:00
Filipi Fuchter	cbd0529674	Merge branch 'main' into filipi/websocket_transport_example_twilio	2025-06-17 15:54:31 -03:00
Filipi da Silva Fuchter	5614e35ac4	Merge pull request #2015 from pipecat-ai/bumping_pipecat_required_versions Bumping pipecat-ai-krisp required version	2025-06-17 15:42:20 -03:00
Aleix Conchillo Flaqué	c11172caba	examples: create transport params async	2025-06-17 11:37:42 -07:00
Filipi Fuchter	11b6e409bb	Bumping pipecat-ai-krisp required version	2025-06-17 15:22:31 -03:00
Aleix Conchillo Flaqué	3dca95aa3c	Merge pull request #2014 from pipecat-ai/aleix/daily-python-0.19.3 update daily-python to 0.19.3	2025-06-17 10:10:23 -07:00
Aleix Conchillo Flaqué	7ddc706434	update daily-python to 0.19.3	2025-06-17 09:30:28 -07:00
Aleix Conchillo Flaqué	20eebb08e9	update CHANGELOG with AWSTranscribeSTTService Polish support	2025-06-16 10:34:56 -07:00
Aleix Conchillo Flaqué	4abf41b85a	Merge pull request #2011 from wuodar/wuodar/polish-lang-aws-transcribe Support polish language in Amazon Transcribe	2025-06-16 10:33:55 -07:00
Aleix Conchillo Flaqué	e426f7ee7c	Merge pull request #2012 from pipecat-ai/aleix/frame-pause-resume-frames FrameProcessor: handle new FrameProcessorPauseFrame/FrameProcessorResumeFrame	2025-06-16 10:32:38 -07:00
Aleix Conchillo Flaqué	14dc6a7984	FrameProcessor: handle new FrameProcessorPauseFrame/FrameProcessorResumeFrame	2025-06-16 10:31:33 -07:00
Mark Backman	e0a24a3f07	Merge pull request #2006 from pipecat-ai/mb/expose-function-calls-in-progress Expose has_function_calls_in_progress property	2025-06-16 12:49:07 -04:00
Mark Backman	d1bee22d73	Expose has_function_calls_in_progress property	2025-06-16 12:45:16 -04:00
Jon Taylor	d73f7908f2	Merge pull request #2008 from pipecat-ai/khk/groq-audio fix groq wav file header parsing	2025-06-16 14:09:09 +01:00
Aleix Conchillo Flaqué	a4ea0d2b82	dev-requirements: update pyright 1.1.400 and ruff 0.11.13	2025-06-15 21:05:03 -07:00
Kacper Włodarczyk	e2c15169b8	feat: support polish language in Amazon Transcribe	2025-06-15 21:44:06 +02:00
Kwindla Hultman Kramer	fe16ed3c73	added changelog entry	2025-06-15 10:49:40 -07:00
Filipi Fuchter	80ce097f90	Using relative URL for the websocket.	2025-06-15 10:49:25 -03:00
Filipi Fuchter	eceaf8a46b	Making the path to the web client relative	2025-06-14 21:07:15 -03:00
Kwindla Hultman Kramer	1e3fa4a9c7	fix groq wav file header parsing	2025-06-14 17:41:44 -04:00
Filipi da Silva Fuchter	dc640a7591	Merge pull request #2001 from pipecat-ai/filipi/google_stt_reconnection_issue Fixed an issue with `GoogleSTTService` where it was constantly reconnecting	2025-06-13 08:29:18 -03:00
Filipi Fuchter	1f072d182c	Merge branch 'main' into filipi/google_stt_reconnection_issue # Conflicts: # CHANGELOG.md	2025-06-13 08:26:00 -03:00
Mark Backman	1d64e04ed5	Merge pull request #2002 from pipecat-ai/mb/google-fix-ttfb Fix: GoogleLLMService TTFB	2025-06-12 12:10:01 -04:00
Mark Backman	22f4f0b79e	Update 14e example name	2025-06-12 11:45:59 -04:00
Mark Backman	69c63293fb	fix: GoogleLLMService TTFB value	2025-06-12 11:43:27 -04:00
Filipi Fuchter	c1db13ceeb	Fixed an issue with `GoogleSTTService` where it was constantly reconnecting before starting to receive audio from the user.	2025-06-12 12:07:33 -03:00
Filipi Fuchter	70eadee0aa	Bumping the @pipecat-ai/websocket-transport dependency.	2025-06-11 18:30:16 -03:00
Aleix Conchillo Flaqué	228afe01ed	Merge pull request #1993 from pipecat-ai/aleix/pipecat-0.0.71 update CHANGELOG for 0.0.71	2025-06-10 14:42:09 -07:00
Aleix Conchillo Flaqué	61a5154e49	update CHANGELOG for 0.0.71	2025-06-10 14:34:30 -07:00
Sunah Suh	d3df75aaa0	Add `additional_span_attributes` param to PipelineTask for extra otel… (#1992 )	2025-06-10 17:32:24 -04:00
Aleix Conchillo Flaqué	c59180dd6e	udpate CHANGELOG	2025-06-10 14:23:02 -07:00
Mark Backman	e4c2310632	Merge pull request #1990 from pipecat-ai/mb/more-cartesia-stt Add Cartesia STT docs link to README, fix set_model error	2025-06-10 17:19:11 -04:00
Mark Backman	257dbe3104	Fix model param error	2025-06-10 15:14:47 -04:00
Mark Backman	cd98657e3c	Add Cartesia STT docs link to README	2025-06-10 15:09:13 -04:00
Filipi Fuchter	0073a868d4	Websocket client web app to test Twilio.	2025-06-10 11:34:02 -03:00
jqueguiner	25ff8ef37b	✨ (config.py): add new configuration options for lip-sync optimization, context adaptation, and additional context to enhance translation accuracy ♻️ (stt.py): increase default max buffer size from 5MB to 20MB to accommodate larger audio data ♻️ (stt.py): simplify audio sending logic by removing chunking and sending the entire buffered audio at once for improved performance	2025-06-05 16:51:29 -07:00
jqueguiner	02cc6f3d56	Enhance GladiaSTTService with reconnection and audio buffer management features - Added parameters for maximum reconnection attempts, reconnection delay, and maximum audio buffer size. - Implemented automatic reconnection logic with exponential backoff. - Introduced audio buffer management to handle audio data efficiently, including trimming excess data. - Updated connection handling to ensure proper cleanup and management of WebSocket connections. - Enhanced audio sending logic to support buffered audio transmission after reconnections.	2025-06-03 03:16:57 -07:00