diff --git a/app/dao/jobs_dao.py b/app/dao/jobs_dao.py
index 30b2b3b07..ea64162b2 100644
--- a/app/dao/jobs_dao.py
+++ b/app/dao/jobs_dao.py
@@ -116,10 +116,11 @@ def dao_set_scheduled_jobs_to_pending():
     from completing until it commits.
     """
     stmt = (
-        select(
+        select(Job)
+        .filter(
             Job.job_status == JobStatus.SCHEDULED,
             Job.scheduled_for < utc_now(),
-        ).select_from(Job)
+        )
         .order_by(asc(Job.scheduled_for))
         .with_for_update()
     )