notifications-api/app/dao/jobs_dao.py

from app import db
from app.models import Job


def save_job(job):
    db.session.add(job)
    db.session.commit()


def get_job(service_id, job_id):
    return Job.query.filter_by(service_id=service_id, id=job_id).one()


def get_jobs_by_service(service_id):
    return Job.query.filter_by(service_id=service_id).all()


def _get_jobs():
    return Job.query.all()