ivooskamp/backupchecks
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Deduplicate Cove runs per job instead of globally

Browse Source
This commit is contained in:
Ivo Oskamp 2026-02-23 12:15:18 +01:00
parent 8fe3f99e40
commit 47bb4ee4f0
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
containers/backupchecks/src/backend/app/cove_importer.py
View File

@ -407,12 +407,6 @@ def _process_account(account: dict) -> bool:
run_ts = int(last_run_ts_raw or 0)
except (TypeError, ValueError):
run_ts = 0
external_id = f"cove-{account_id}-{run_ts}"
existing = JobRun.query.filter_by(external_id=external_id).first()
if existing:
db.session.commit()
return False
# Fetch the linked job
from .models import Job
@ -421,6 +415,16 @@ def _process_account(account: dict) -> bool:
db.session.commit()
return False
external_id = f"cove-{account_id}-{run_ts}"
# Deduplicate per job + session, not globally.
# This avoids blocking a run on a newly linked/relinked job when the same
# Cove session was previously stored under another job.
existing = JobRun.query.filter_by(job_id=job.id, external_id=external_id).first()
if existing:
db.session.commit()
return False
status = _map_status(last_status_code)
run_remark = (
f"Cove account: {account_name or account_id} | "