[fix] Define redis password via env

someengineering · Jul 31, 2024 · f445880 · f445880
1 parent 04fd40e
commit f445880
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/collect_coordinator/worker_queue.py b/collect_coordinator/worker_queue.py
@@ -291,6 +291,10 @@ def parse_post_collect_definition_json(self, js: Json) -> JobDefinition:
         ]
         # fmt: on
 
+        # Make passwords available via env
+        if redis_password := self.credentials.get("redis_password"):
+            env["REDIS_PASSWORD"] = redis_password
+
         # each job run is for one tenant and all collected accounts
         return JobDefinition(
             app="post-collect-job",