new jobs query to get all scheduled jobs

app/dao/jobs_dao.py

@@ -1,6 +1,6 @@
-from datetime import date, timedelta
+from datetime import date, timedelta, datetime
 
-from sqlalchemy import desc, cast, Date as sql_date
+from sqlalchemy import desc, asc, cast, Date as sql_date
 from app import db
 from app.dao import days_ago
 from app.models import Job
@@ -21,6 +21,13 @@ def dao_get_job_by_id(job_id):
     return Job.query.filter_by(id=job_id).one()
 
 
+def dao_get_scheduled_jobs():
+    return Job.query \
+        .filter(Job.job_status == 'scheduled', Job.scheduled_for < datetime.utcnow()) \
+        .order_by(asc(Job.scheduled_for)) \
+        .all()
+
+
 def dao_create_job(job):
     db.session.add(job)
     db.session.commit()