Update redis connection for docker compose

programminghistorian · Aug 25, 2019 · b4ec19c · b4ec19c
1 parent 245a7e3
commit b4ec19c
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/processor.py b/processor.py
@@ -17,13 +17,15 @@
 
 lbp_config.cache_dir = "cache"
 
-q = Queue(connection=Redis())
+redis_connection = Redis(host="redis")
+
+q = Queue(connection=redis_connection)
 
 
 def handle_job(resource_value: str, resource_type: str) -> dict:
  try:
  logger.debug(f"Checking for job with the id {resource_value}")
- job = Job.fetch(resource_value, connection=Redis())
+ job = Job.fetch(resource_value, connection=redis_connection)
  except NoSuchJobError:
  logger.debug(f"No existing job. Starting one up ...")
  job = q.enqueue(