Fix UnboundLocalError for is_coordinator when all frames already upscaled

2026-06-30 09:22:41 -04:00
parent 1c8c95d618
commit ae4f42e903
1 changed files with 1 additions and 0 deletions
@@ -401,6 +401,7 @@ def run_upscale_pipeline(job: UpscaleJob, on_progress_update: Callable[[str, Dic
                print(f"Job {job.job_id}: Skipping {skipped_frames} already upscaled frames.")

        remaining_inputs = len(os.listdir(input_frames_dir)) if os.path.exists(input_frames_dir) else 0
+        is_coordinator = False
        
        if remaining_inputs == 0:
            print(f"Job {job.job_id}: All frames already upscaled. Skipping upscaling step.")