From 771781096e959d00580d46f6b71fa6fa0709e9cb Mon Sep 17 00:00:00 2001
From: Abhishek Kumar <abhishek@a6k.me>
Date: Sat, 7 Mar 2026 12:41:24 +0530
Subject: [PATCH] feat: add early voicemail detection

---
 api/services/pipecat/run_pipeline.py    | 3 ++-
 api/services/pipecat/service_factory.py | 1 +
 pipecat                                 | 2 +-
 3 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/api/services/pipecat/run_pipeline.py b/api/services/pipecat/run_pipeline.py
index 65f3c93..69a8907 100644
--- a/api/services/pipecat/run_pipeline.py
+++ b/api/services/pipecat/run_pipeline.py
@@ -667,7 +667,8 @@ async def _run_pipeline(
         voicemail_llm = create_llm_service(user_config)
         voicemail_detector = VoicemailDetector(
             llm=voicemail_llm,
-            voicemail_response_delay=2.0,
+            voicemail_response_delay=1.0,
+            long_speech_timeout=8.0,
         )
 
         # Register event handler to end task when voicemail is detected
diff --git a/api/services/pipecat/service_factory.py b/api/services/pipecat/service_factory.py
index 07a7d04..5e1a813 100644
--- a/api/services/pipecat/service_factory.py
+++ b/api/services/pipecat/service_factory.py
@@ -53,6 +53,7 @@ def create_stt_service(
                 params=DeepgramFluxSTTService.InputParams(
                     eot_timeout_ms=3000,
                     eot_threshold=0.7,
+                    eager_eot_threshold=0.5,
                     keyterm=keyterms or [],
                 ),
                 should_interrupt=False,  # Let UserAggregator take care of sending InterruptionFrame
diff --git a/pipecat b/pipecat
index 8bc718e..b687767 160000
--- a/pipecat
+++ b/pipecat
@@ -1 +1 @@
-Subproject commit 8bc718e6f136cb19814db5b8ce8412ae3a6ed393
+Subproject commit b6877678e9ee78d5d96960b072729b77ae247b6d