Upload 14 files

pipeline/orchestrator.py

@@ -381,6 +381,9 @@ def sync_workers(tracker):
         if kstatus == "complete":
             log.info(f"  ✅ {title} completed")
             tracker.mark_worker(wid, WS_COMPLETE, kstatus)
+            requeued = tracker.requeue_worker_videos(wid, new_status=S_FAILED)
+            if requeued > 0:
+                log.info(f"     Marked {requeued} silently skipped videos as failed")
         elif kstatus == "error":
             log.warning(f"  ❌ {title} errored")
             requeued = tracker.requeue_worker_videos(wid)