From 3cf9757ac24be92b771086c5b0d5313af5ca9595 Mon Sep 17 00:00:00 2001
From: Igor Monadical <igor@monadical.com>
Date: Tue, 23 Dec 2025 17:35:43 -0500
Subject: [PATCH] diarization flow - pralellelize better (#808)

Co-authored-by: Igor Loskutov <igor.loskutoff@gmail.com>
---
 server/reflector/hatchet/workflows/diarization_pipeline.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/server/reflector/hatchet/workflows/diarization_pipeline.py b/server/reflector/hatchet/workflows/diarization_pipeline.py
index 1557e2c6..2ec97179 100644
--- a/server/reflector/hatchet/workflows/diarization_pipeline.py
+++ b/server/reflector/hatchet/workflows/diarization_pipeline.py
@@ -556,7 +556,7 @@ async def generate_waveform(input: PipelineInput, ctx: Context) -> WaveformResul
 
 
 @diarization_pipeline.task(
-    parents=[mixdown_tracks],
+    parents=[process_tracks],
     execution_timeout=timedelta(seconds=TIMEOUT_HEAVY),
     retries=3,
 )