From 8fcd2a4c1796f92239142278f185cd17e12d8765 Mon Sep 17 00:00:00 2001 From: Scott Koranda Date: Tue, 12 Nov 2019 09:46:09 -0600 Subject: [PATCH] Add Redis host and port to RedisJobStore Fix to pass the redis_host and redis_port to the apscheduler RedisJobStore() instantiation. --- src/pyff/utils.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/pyff/utils.py b/src/pyff/utils.py index 3894fa5c..c565a6e5 100644 --- a/src/pyff/utils.py +++ b/src/pyff/utils.py @@ -827,7 +827,7 @@ def non_blocking_lock(lock=threading.Lock(), exception_class=ResourceException, def make_default_scheduler(): if config.scheduler_job_store == 'redis': - jobstore = RedisJobStore() + jobstore = RedisJobStore(host=config.redis_host, port=config.redis_port) elif config.scheduler_job_store == 'memory': jobstore = MemoryJobStore() else: