Set rq redis connection by url.

tschaefer · Dec 18, 2023 · 6b6f3d0 · 6b6f3d0
1 parent f672eed
commit 6b6f3d0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/beetsplug/store/tasks.py b/beetsplug/store/tasks.py
@@ -41,7 +41,8 @@ def job_failed(job, connection, *args, **kwargs):
 
 class Task:
     def __init__(self):
-        self.q = Queue(connection=Redis())
+        redis_url = os.getenv('BEETS_REDIS_URL', 'redis://localhost:6379')
+        self.q = Queue(connection=Redis.from_url(redis_url))
 
     def run(self, name='bundle', arguments=None):
         return self.q.enqueue(globals()[name], arguments,