Upload app.py

app.py

@@ -442,6 +442,20 @@ def run_verify_repo(repo_id):
     except Exception as e:
         return f"Error: {e}"
 
+autopilot_process = None
+
+def toggle_autopilot(videos_per_worker):
+    global autopilot_process
+    
+    if autopilot_process is not None and autopilot_process.poll() is None:
+        autopilot_process.terminate()
+        autopilot_process = None
+        return "🛑 Autopilot stopped."
+    else:
+        cmd = ["python", "pipeline/orchestrator.py", "run", "--videos-per-worker", str(int(videos_per_worker))]
+        autopilot_process = subprocess.Popen(cmd, cwd=os.path.dirname(os.path.abspath(__file__)))
+        return "🚀 Autopilot started! It is now running continuously in the background, checking Kaggle every 2 minutes and instantly launching new workers whenever slots free up."
+
 with gr.Blocks() as app:
     gr.Markdown("# YouTube Video Orchestrator Host")
     gr.Markdown("Deploy this to Hugging Face Spaces or run locally. It fetches pending links from your database and delegates them to FastAPI workers or Kaggle.")
@@ -456,6 +470,7 @@ with gr.Blocks() as app:
                 
             with gr.Row():
                 v3_launch_btn = gr.Button("Launch Workers (--push)", variant="primary")
+                v3_autopilot_btn = gr.Button("Toggle Autopilot", variant="secondary")
                 v3_sync_btn = gr.Button("Sync DB & Status")
                 v3_status_btn = gr.Button("Check Status")
                 v3_retry_btn = gr.Button("Retry Failed Videos")
@@ -470,6 +485,7 @@ with gr.Blocks() as app:
             v3_output_log = gr.Textbox(label="Terminal Output", lines=15)
             
             v3_launch_btn.click(fn=run_v3_launch, inputs=[v3_max_workers, v3_videos], outputs=v3_output_log)
+            v3_autopilot_btn.click(fn=toggle_autopilot, inputs=[v3_videos], outputs=v3_output_log)
             v3_sync_btn.click(fn=run_v3_sync, inputs=[], outputs=v3_output_log)
             v3_status_btn.click(fn=run_v3_status, inputs=[], outputs=v3_output_log)
             v3_retry_btn.click(fn=run_v3_retry, inputs=[], outputs=v3_output_log)