From 8376e3e949fc72b682d9b696a6ff640be79d51f9 Mon Sep 17 00:00:00 2001 From: Abhishek Kumar Date: Wed, 24 Sep 2025 13:36:36 +0530 Subject: [PATCH] Feat: set start metadata in pipeline This is needed so that we can send correlation id for workflow runs in Dograh MPS --- api/Dockerfile | 2 +- api/requirements.txt | 2 +- api/services/pipecat/pipeline_builder.py | 1 + 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/api/Dockerfile b/api/Dockerfile index 624ab0c..1e861cf 100644 --- a/api/Dockerfile +++ b/api/Dockerfile @@ -21,7 +21,7 @@ RUN pip install --user --no-cache-dir -r requirements.txt && \ # Force reinstall of pipecat on every build (cache bust) ARG CACHEBUST=1 -RUN pip install --user 'git+https://github.com/dograh-hq/pipecat.git@9dbd5eb#egg=pipecat-ai[cartesia,deepgram,openai,elevenlabs,groq,google,azure]' && \ +RUN pip install --user 'git+https://github.com/dograh-hq/pipecat.git@bcbd158#egg=pipecat-ai[cartesia,deepgram,openai,elevenlabs,groq,google,azure]' && \ # Clean up pip cache after pipecat installation rm -rf /root/.cache/pip diff --git a/api/requirements.txt b/api/requirements.txt index bc5821a..e8acbc0 100644 --- a/api/requirements.txt +++ b/api/requirements.txt @@ -1,4 +1,4 @@ -pipecat-ai[cartesia,deepgram,openai,elevenlabs,groq,google,azure,soundfile,silero,webrtc] @ git+https://github.com/dograh-hq/pipecat.git@c327208 +pipecat-ai[cartesia,deepgram,openai,elevenlabs,groq,google,azure,soundfile,silero,webrtc] @ git+https://github.com/dograh-hq/pipecat.git@bcbd158 langfuse==3.4.0 fastapi==0.116.2 asyncpg==0.30.0 diff --git a/api/services/pipecat/pipeline_builder.py b/api/services/pipecat/pipeline_builder.py index cab5317..d4562f5 100644 --- a/api/services/pipecat/pipeline_builder.py +++ b/api/services/pipecat/pipeline_builder.py @@ -105,6 +105,7 @@ def create_pipeline_task(pipeline, workflow_run_id, audio_config: AudioConfig = enable_usage_metrics=True, send_initial_empty_metrics=False, enable_heartbeats=True, + start_metadata={"workflow_run_id": workflow_run_id}, ) # If audio_config is provided, set the audio sample rates