From cff9674c9efae53e6fffb910776529ef03dca04c Mon Sep 17 00:00:00 2001 From: Abhishek Kumar Date: Wed, 11 Feb 2026 18:18:32 +0530 Subject: [PATCH] chore: bump pipecat version --- api/logging_config.py | 2 +- api/routes/stasis_rtp.py | 2 +- api/routes/telephony.py | 2 +- api/routes/webrtc_signaling.py | 2 +- api/services/looptalk/orchestrator.py | 2 +- api/services/pipecat/pipeline_builder.py | 2 +- api/services/pipecat/run_pipeline.py | 6 +++--- api/services/pipecat/turn_context.py | 2 +- api/services/telephony/worker_event_subscriber.py | 2 +- api/tasks/run_integrations.py | 2 +- api/tasks/s3_upload.py | 2 +- api/tasks/workflow_run_cost.py | 2 +- api/tests/test_pipecat_engine_context_update.py | 2 +- api/tests/test_pipecat_engine_end_call.py | 2 +- .../test_pipecat_engine_node_switch_with_user_speech.py | 2 +- api/tests/test_pipecat_engine_tool_calls.py | 2 +- api/tests/test_pipecat_engine_variable_extraction.py | 2 +- api/tests/test_tts_endframe_with_audio_write_failure.py | 2 +- api/tests/test_user_idle_handler.py | 2 +- api/tests/test_user_muting_during_bot_speech.py | 2 +- api/tests/test_voicemail_detector.py | 2 +- pipecat | 2 +- 22 files changed, 24 insertions(+), 24 deletions(-) diff --git a/api/logging_config.py b/api/logging_config.py index 37f5ea3..dc44b69 100644 --- a/api/logging_config.py +++ b/api/logging_config.py @@ -7,7 +7,7 @@ import loguru from api.constants import SERIALIZE_LOG_OUTPUT from api.enums import Environment from api.utils.worker import get_worker_id, is_worker_process -from pipecat.utils.context import run_id_var, turn_var +from pipecat.utils.run_context import run_id_var, turn_var ENVIRONMENT = os.getenv("ENVIRONMENT", Environment.LOCAL.value) ENABLE_TURN_LOGGING = os.getenv("ENABLE_TURN_LOGGING", "false").lower() == "true" diff --git a/api/routes/stasis_rtp.py b/api/routes/stasis_rtp.py index c18682a..0fede33 100644 --- a/api/routes/stasis_rtp.py +++ b/api/routes/stasis_rtp.py @@ -1,12 +1,12 @@ import random from loguru import logger -from pipecat.utils.context import set_current_run_id from api.db import db_client from api.enums import WorkflowRunMode from api.services.pipecat.run_pipeline import run_pipeline_ari_stasis from api.services.telephony.stasis_rtp_connection import StasisRTPConnection +from pipecat.utils.run_context import set_current_run_id async def on_stasis_call(call: StasisRTPConnection, call_context_vars: dict): diff --git a/api/routes/telephony.py b/api/routes/telephony.py index 0ed6c87..e93dd60 100644 --- a/api/routes/telephony.py +++ b/api/routes/telephony.py @@ -37,7 +37,7 @@ from api.utils.telephony_helper import ( numbers_match, parse_webhook_request, ) -from pipecat.utils.context import set_current_run_id +from pipecat.utils.run_context import set_current_run_id router = APIRouter(prefix="/telephony") diff --git a/api/routes/webrtc_signaling.py b/api/routes/webrtc_signaling.py index f50180d..d33aa5d 100644 --- a/api/routes/webrtc_signaling.py +++ b/api/routes/webrtc_signaling.py @@ -44,7 +44,7 @@ from api.services.pipecat.ws_sender_registry import ( ) from api.services.quota_service import check_dograh_quota from pipecat.transports.smallwebrtc.connection import SmallWebRTCConnection -from pipecat.utils.context import set_current_run_id +from pipecat.utils.run_context import set_current_run_id router = APIRouter(prefix="/ws") diff --git a/api/services/looptalk/orchestrator.py b/api/services/looptalk/orchestrator.py index 917774a..d4c969a 100644 --- a/api/services/looptalk/orchestrator.py +++ b/api/services/looptalk/orchestrator.py @@ -14,7 +14,7 @@ from api.services.looptalk.internal_transport import ( ) from api.services.pipecat.transport_setup import create_internal_transport from pipecat.pipeline.task import PipelineTask -from pipecat.utils.context import set_current_run_id +from pipecat.utils.run_context import set_current_run_id from .core.pipeline_builder import LoopTalkPipelineBuilder from .core.recording_manager import RecordingManager diff --git a/api/services/pipecat/pipeline_builder.py b/api/services/pipecat/pipeline_builder.py index 1706a2e..0080770 100644 --- a/api/services/pipecat/pipeline_builder.py +++ b/api/services/pipecat/pipeline_builder.py @@ -10,7 +10,7 @@ from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.task import PipelineParams, PipelineTask from pipecat.processors.aggregators.llm_context import LLMContext from pipecat.processors.audio.audio_buffer_processor import AudioBufferProcessor -from pipecat.utils.context import turn_var +from pipecat.utils.run_context import turn_var def create_pipeline_components(audio_config: AudioConfig): diff --git a/api/services/pipecat/run_pipeline.py b/api/services/pipecat/run_pipeline.py index ddffa9c..41a1882 100644 --- a/api/services/pipecat/run_pipeline.py +++ b/api/services/pipecat/run_pipeline.py @@ -70,12 +70,12 @@ from pipecat.turns.user_start.vad_user_turn_start_strategy import ( ) from pipecat.turns.user_stop import ( ExternalUserTurnStopStrategy, - TranscriptionUserTurnStopStrategy, + SpeechTimeoutUserTurnStopStrategy, TurnAnalyzerUserTurnStopStrategy, ) from pipecat.turns.user_turn_strategies import UserTurnStrategies -from pipecat.utils.context import set_current_run_id from pipecat.utils.enums import EndTaskReason +from pipecat.utils.run_context import set_current_run_id from pipecat.utils.tracing.context_registry import ContextProviderRegistry # Setup tracing if enabled @@ -602,7 +602,7 @@ async def _run_pipeline( # Transcription-based (default): best for short 1-2 word responses user_turn_strategies = UserTurnStrategies( start=[VADUserTurnStartStrategy(), TranscriptionUserTurnStartStrategy()], - stop=[TranscriptionUserTurnStopStrategy()], + stop=[SpeechTimeoutUserTurnStopStrategy()], ) # Create user mute strategies diff --git a/api/services/pipecat/turn_context.py b/api/services/pipecat/turn_context.py index 9d3683d..05e6e4d 100644 --- a/api/services/pipecat/turn_context.py +++ b/api/services/pipecat/turn_context.py @@ -8,7 +8,7 @@ propagate through asyncio.create_task() calls. import asyncio from typing import Dict, Optional -from pipecat.utils.context import turn_var +from pipecat.utils.run_context import turn_var class TurnContextManager: diff --git a/api/services/telephony/worker_event_subscriber.py b/api/services/telephony/worker_event_subscriber.py index 42afb39..6126372 100644 --- a/api/services/telephony/worker_event_subscriber.py +++ b/api/services/telephony/worker_event_subscriber.py @@ -23,7 +23,7 @@ from api.services.telephony.stasis_event_protocol import ( parse_event, ) from api.services.telephony.stasis_rtp_connection import StasisRTPConnection -from pipecat.utils.context import set_current_run_id +from pipecat.utils.run_context import set_current_run_id class WorkerEventSubscriber: diff --git a/api/tasks/run_integrations.py b/api/tasks/run_integrations.py index fb38e5c..b622f38 100644 --- a/api/tasks/run_integrations.py +++ b/api/tasks/run_integrations.py @@ -10,7 +10,7 @@ from api.db import db_client from api.db.models import WorkflowRunModel from api.utils.credential_auth import build_auth_header from api.utils.template_renderer import render_template -from pipecat.utils.context import set_current_run_id +from pipecat.utils.run_context import set_current_run_id async def run_integrations_post_workflow_run(_ctx, workflow_run_id: int): diff --git a/api/tasks/s3_upload.py b/api/tasks/s3_upload.py index d1c55a6..f1b821d 100644 --- a/api/tasks/s3_upload.py +++ b/api/tasks/s3_upload.py @@ -6,7 +6,7 @@ from loguru import logger from api.db import db_client from api.services.storage import get_current_storage_backend, storage_fs from api.tasks.run_integrations import run_integrations_post_workflow_run -from pipecat.utils.context import set_current_run_id +from pipecat.utils.run_context import set_current_run_id async def upload_voicemail_audio_to_s3( diff --git a/api/tasks/workflow_run_cost.py b/api/tasks/workflow_run_cost.py index 25400fc..a0c06a1 100644 --- a/api/tasks/workflow_run_cost.py +++ b/api/tasks/workflow_run_cost.py @@ -4,7 +4,7 @@ from api.db import db_client from api.enums import WorkflowRunMode from api.services.pricing.cost_calculator import cost_calculator from api.services.telephony.factory import get_telephony_provider -from pipecat.utils.context import set_current_run_id +from pipecat.utils.run_context import set_current_run_id async def calculate_workflow_run_cost(ctx, workflow_run_id: int): diff --git a/api/tests/test_pipecat_engine_context_update.py b/api/tests/test_pipecat_engine_context_update.py index d40be6c..cb99cdf 100644 --- a/api/tests/test_pipecat_engine_context_update.py +++ b/api/tests/test_pipecat_engine_context_update.py @@ -31,8 +31,8 @@ from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner from pipecat.pipeline.task import PipelineParams, PipelineTask from pipecat.processors.aggregators.llm_context import LLMContext -from pipecat.processors.aggregators.llm_response import LLMAssistantAggregatorParams from pipecat.processors.aggregators.llm_response_universal import ( + LLMAssistantAggregatorParams, LLMContextAggregatorPair, ) from pipecat.tests import MockLLMService, MockTTSService diff --git a/api/tests/test_pipecat_engine_end_call.py b/api/tests/test_pipecat_engine_end_call.py index 46fa248..78bb020 100644 --- a/api/tests/test_pipecat_engine_end_call.py +++ b/api/tests/test_pipecat_engine_end_call.py @@ -46,8 +46,8 @@ from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner from pipecat.pipeline.task import PipelineParams, PipelineTask from pipecat.processors.aggregators.llm_context import LLMContext -from pipecat.processors.aggregators.llm_response import LLMAssistantAggregatorParams from pipecat.processors.aggregators.llm_response_universal import ( + LLMAssistantAggregatorParams, LLMContextAggregatorPair, LLMUserAggregatorParams, ) diff --git a/api/tests/test_pipecat_engine_node_switch_with_user_speech.py b/api/tests/test_pipecat_engine_node_switch_with_user_speech.py index e65e036..efad8fd 100644 --- a/api/tests/test_pipecat_engine_node_switch_with_user_speech.py +++ b/api/tests/test_pipecat_engine_node_switch_with_user_speech.py @@ -30,8 +30,8 @@ from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner from pipecat.pipeline.task import PipelineParams, PipelineTask from pipecat.processors.aggregators.llm_context import LLMContext -from pipecat.processors.aggregators.llm_response import LLMAssistantAggregatorParams from pipecat.processors.aggregators.llm_response_universal import ( + LLMAssistantAggregatorParams, LLMContextAggregatorPair, LLMUserAggregatorParams, ) diff --git a/api/tests/test_pipecat_engine_tool_calls.py b/api/tests/test_pipecat_engine_tool_calls.py index 7938df8..43a05c4 100644 --- a/api/tests/test_pipecat_engine_tool_calls.py +++ b/api/tests/test_pipecat_engine_tool_calls.py @@ -18,8 +18,8 @@ from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner from pipecat.pipeline.task import PipelineParams, PipelineTask from pipecat.processors.aggregators.llm_context import LLMContext -from pipecat.processors.aggregators.llm_response import LLMAssistantAggregatorParams from pipecat.processors.aggregators.llm_response_universal import ( + LLMAssistantAggregatorParams, LLMContextAggregatorPair, ) from pipecat.tests import MockLLMService, MockTTSService diff --git a/api/tests/test_pipecat_engine_variable_extraction.py b/api/tests/test_pipecat_engine_variable_extraction.py index 3159379..8a51614 100644 --- a/api/tests/test_pipecat_engine_variable_extraction.py +++ b/api/tests/test_pipecat_engine_variable_extraction.py @@ -27,8 +27,8 @@ from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner from pipecat.pipeline.task import PipelineParams, PipelineTask from pipecat.processors.aggregators.llm_context import LLMContext -from pipecat.processors.aggregators.llm_response import LLMAssistantAggregatorParams from pipecat.processors.aggregators.llm_response_universal import ( + LLMAssistantAggregatorParams, LLMContextAggregatorPair, ) from pipecat.tests import MockLLMService, MockTTSService diff --git a/api/tests/test_tts_endframe_with_audio_write_failure.py b/api/tests/test_tts_endframe_with_audio_write_failure.py index 7350964..fa0dba6 100644 --- a/api/tests/test_tts_endframe_with_audio_write_failure.py +++ b/api/tests/test_tts_endframe_with_audio_write_failure.py @@ -43,8 +43,8 @@ from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner from pipecat.pipeline.task import PipelineParams, PipelineTask from pipecat.processors.aggregators.llm_context import LLMContext -from pipecat.processors.aggregators.llm_response import LLMAssistantAggregatorParams from pipecat.processors.aggregators.llm_response_universal import ( + LLMAssistantAggregatorParams, LLMContextAggregatorPair, LLMUserAggregatorParams, ) diff --git a/api/tests/test_user_idle_handler.py b/api/tests/test_user_idle_handler.py index 3b01df0..4548ca7 100644 --- a/api/tests/test_user_idle_handler.py +++ b/api/tests/test_user_idle_handler.py @@ -29,8 +29,8 @@ from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner from pipecat.pipeline.task import PipelineParams, PipelineTask from pipecat.processors.aggregators.llm_context import LLMContext -from pipecat.processors.aggregators.llm_response import LLMAssistantAggregatorParams from pipecat.processors.aggregators.llm_response_universal import ( + LLMAssistantAggregatorParams, LLMContextAggregatorPair, LLMUserAggregatorParams, ) diff --git a/api/tests/test_user_muting_during_bot_speech.py b/api/tests/test_user_muting_during_bot_speech.py index b127e68..6fd6b78 100644 --- a/api/tests/test_user_muting_during_bot_speech.py +++ b/api/tests/test_user_muting_during_bot_speech.py @@ -34,8 +34,8 @@ from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner from pipecat.pipeline.task import PipelineParams, PipelineTask from pipecat.processors.aggregators.llm_context import LLMContext -from pipecat.processors.aggregators.llm_response import LLMAssistantAggregatorParams from pipecat.processors.aggregators.llm_response_universal import ( + LLMAssistantAggregatorParams, LLMContextAggregatorPair, LLMUserAggregator, LLMUserAggregatorParams, diff --git a/api/tests/test_voicemail_detector.py b/api/tests/test_voicemail_detector.py index d0681c2..64511ee 100644 --- a/api/tests/test_voicemail_detector.py +++ b/api/tests/test_voicemail_detector.py @@ -21,8 +21,8 @@ from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner from pipecat.pipeline.task import PipelineParams, PipelineTask from pipecat.processors.aggregators.llm_context import LLMContext -from pipecat.processors.aggregators.llm_response import LLMAssistantAggregatorParams from pipecat.processors.aggregators.llm_response_universal import ( + LLMAssistantAggregatorParams, LLMContextAggregatorPair, LLMUserAggregatorParams, ) diff --git a/pipecat b/pipecat index 3de34e0..0df2d1d 160000 --- a/pipecat +++ b/pipecat @@ -1 +1 @@ -Subproject commit 3de34e0c4bb2e5d5b564ae801ba276eeb9f3fcdb +Subproject commit 0df2d1d36f30e285bfd4dbe287c18c0dc9ea397e