From f163111b4a69ba0173f0ac11adbd43a577f62f72 Mon Sep 17 00:00:00 2001 From: Igor Loskutov Date: Fri, 19 Dec 2025 21:07:12 -0500 Subject: [PATCH] durable_started return --- server/reflector/worker/process.py | 3 --- 1 file changed, 3 deletions(-) diff --git a/server/reflector/worker/process.py b/server/reflector/worker/process.py index b33b2b7d..6d1aa21e 100644 --- a/server/reflector/worker/process.py +++ b/server/reflector/worker/process.py @@ -323,9 +323,6 @@ async def _process_multitrack_recording_inner( await transcripts_controller.update( transcript, {"workflow_run_id": workflow_id} ) - durable_started = True - - if durable_started: return # Celery pipeline (runs when durable workflows disabled)