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)