From 42bde5adb6b2c7c876986f169b7a794cf8360894 Mon Sep 17 00:00:00 2001 From: Igor Loskutov Date: Mon, 22 Dec 2025 15:59:52 -0500 Subject: [PATCH] comments --- server/reflector/services/transcript_process.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/server/reflector/services/transcript_process.py b/server/reflector/services/transcript_process.py index 0400db3e..1c36d0e9 100644 --- a/server/reflector/services/transcript_process.py +++ b/server/reflector/services/transcript_process.py @@ -116,13 +116,11 @@ async def validate_transcript_for_processing( ): return ValidationAlreadyScheduled(detail="already running") - # Check Hatchet workflows (if enabled) if settings.HATCHET_ENABLED and transcript.workflow_run_id: try: status = await HatchetClientManager.get_workflow_run_status( transcript.workflow_run_id ) - # If workflow is running or queued, don't allow new processing if status in (V1TaskStatus.RUNNING, V1TaskStatus.QUEUED): return ValidationAlreadyScheduled( detail="Hatchet workflow already running"