diff --git a/scripts/dispatcher.py b/scripts/dispatcher.py index 1bc99dc..c4e1f36 100644 --- a/scripts/dispatcher.py +++ b/scripts/dispatcher.py @@ -297,8 +297,9 @@ def _maybe_create_per_auv_stitch(job_id: int): if not job: return acq_id, auv = job["acquisition_id"], job["auv"] + # Skip jobs flagged 'skipped' (bad segments: GoPro on deck, no underwater content). total = conn.execute( - "SELECT COUNT(*) FROM jobs WHERE acquisition_id=? AND auv=?", (acq_id, auv) + "SELECT COUNT(*) FROM jobs WHERE acquisition_id=? AND auv=? AND status != 'skipped'", (acq_id, auv) ).fetchone()[0] done = conn.execute( "SELECT COUNT(*) FROM jobs WHERE acquisition_id=? AND auv=? AND status='done'", (acq_id, auv) @@ -311,7 +312,7 @@ def _maybe_create_per_auv_stitch(job_id: int): if existing: return job_ids = [r["id"] for r in conn.execute( - "SELECT id FROM jobs WHERE acquisition_id=? AND auv=?", (acq_id, auv) + "SELECT id FROM jobs WHERE acquisition_id=? AND auv=? AND status='done'", (acq_id, auv) ).fetchall()] conn.execute( "INSERT INTO stitches (acquisition_id, level, auv, input_job_ids) VALUES (?,?,?,?)",