RedisJobStore на языке Python не хранит задания в кэше Redis - PullRequest
0 голосов
/ 25 февраля 2019

Это мой код на Python: все задания запускаются в нужное время, но не сохраняются как кэш redis.Если перезапустить программу, не может запланировать ожидающие работы.Что я делаю не так?

from apscheduler.jobstores.redis import RedisJobStore
from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor

if __name__ == '__main__':

    jobstores = {
        'redis': RedisJobStore(jobs_key='dispatched_trips_jobs', run_times_key='dispatched_trips_running', host='localhost', port=6379)
    }
    executors = {
        'default': ThreadPoolExecutor(100),
        'processpool': ProcessPoolExecutor(5)
    }

    scheduler = BackgroundScheduler(jobstores=jobstores, executors=executors)


    scheduler.start()

    while True:
        pass

1 Ответ

0 голосов
/ 05 марта 2019

Изменение строк

jobstores = {
    'redis': RedisJobStore(jobs_key='dispatched_trips_jobs', run_times_key='dispatched_trips_running', host='localhost', port=6379)
}

на

jobstores = {
    'default': RedisJobStore(jobs_key='dispatched_trips_jobs', run_times_key='dispatched_trips_running', host='localhost', port=6379)
}

отлично работает

...