Feat: set start metadata in pipeline

This is needed so that we can send correlation id for workflow runs in Dograh MPS
This commit is contained in:
Abhishek Kumar 2025-09-24 13:36:36 +05:30
parent 9cb75829cb
commit 8376e3e949
3 changed files with 3 additions and 2 deletions

View file

@ -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