APScheduler + Redis + PoolProcessExecutor

example.py

from apscheduler.executors.pool import ProcessPoolExecutor, ThreadPoolExecutor
from apscheduler.jobstores.redis import RedisJobStore
from apscheduler.schedulers.background import BlockingScheduler
from apscheduler.triggers.cron import CronTrigger
from func import heart_beat

if __name__ == "__main__":
    executors = {
        'default': ThreadPoolExecutor(max_workers=10),
        'processpool': ProcessPoolExecutor(max_workers=5)
    }
    jobstores = {'redis': RedisJobStore()}
    scheduler = BlockingScheduler(jobstores=jobstores, executors=executors)

    scheduler.add_job(
        id="pooljob",
        func=heart_beat,
        replace_existing=True,
        trigger=CronTrigger.from_crontab("* * * * *"),
        jobstore='redis',
        executor="processpool",
    )
    scheduler.start()

func.py

from datetime import datetime


def heart_beat():
    print(f"now: {datetime.now()}")