From aa4c368479628ea986c9195a5cd0195af735570e Mon Sep 17 00:00:00 2001 From: Igor Loskutov Date: Fri, 23 Jan 2026 16:40:57 -0500 Subject: [PATCH] Fix critical bugs from refactoring - Fix empty transcript broadcast (was sending text="", should send merged_transcript.text) - Restore generate_waveform to finalize parents (finalize must wait for waveform) --- .../hatchet/workflows/daily_multitrack_pipeline.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/server/reflector/hatchet/workflows/daily_multitrack_pipeline.py b/server/reflector/hatchet/workflows/daily_multitrack_pipeline.py index 7f0e4198..752dda8a 100644 --- a/server/reflector/hatchet/workflows/daily_multitrack_pipeline.py +++ b/server/reflector/hatchet/workflows/daily_multitrack_pipeline.py @@ -1141,7 +1141,7 @@ async def identify_action_items( @daily_multitrack_pipeline.task( - parents=[generate_title, generate_recap, identify_action_items], + parents=[generate_waveform, generate_title, generate_recap, identify_action_items], execution_timeout=timedelta(seconds=TIMEOUT_SHORT), retries=3, ) @@ -1196,8 +1196,8 @@ async def finalize(input: PipelineInput, ctx: Context) -> FinalizeResult: transcript, "TRANSCRIPT", TranscriptText( - text="", - translation=None, + text=merged_transcript.text, + translation=merged_transcript.translation, ), logger=logger, )