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"