diff --git a/app/upscaler.py b/app/upscaler.py
index d19dbdf..431618c 100644
--- a/app/upscaler.py
+++ b/app/upscaler.py
@@ -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.")