actioner/actioner/scheduler/__init__.py

from apscheduler.executors.pool import ThreadPoolExecutor
from apscheduler.schedulers.blocking import BlockingScheduler
from apscheduler.triggers.interval import IntervalTrigger

from .todoist_assigned_issues import todoist_assigned_issues
from .todoist_repo_prs import todoist_repo_prs


def create_scheduler():
    scheduler = BlockingScheduler(executors={"default": ThreadPoolExecutor()})
    scheduler.add_job(todoist_assigned_issues, "interval", minutes=15)
    scheduler.add_job(todoist_repo_prs, "interval", minutes=15)

    for job in scheduler.get_jobs():
        if isinstance(job.trigger, IntervalTrigger):
            scheduler.add_job(job.func)

    return scheduler