diff --git a/app/main.py b/app/main.py index 8671bb6..cbcfebd 100755 --- a/app/main.py +++ b/app/main.py @@ -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() )