bugfix sql-statement for deleting jobs

2026-09-28 15:49:34 +02:00
parent 0d2333694e
commit 1a8f654de9
1 changed files with 3 additions and 2 deletions
@@ -450,12 +450,13 @@ def _run_remote_job_cleanup_maintenance() -> None:
    try:
        assets = (
            db.query(Asset)
-            .join(SoftwareJob, SoftwareJob.asset_id == Asset.id)
            .filter(
                Asset.mesh_node_id.isnot(None),
                Asset.mesh_online.is_(True),
+                db.query(SoftwareJob.id)
+                .filter(SoftwareJob.asset_id == Asset.id)
+                .exists(),
            )
-            .distinct()
            .order_by(Asset.id)
            .all()
        )