remove use of deprecated rq.Connection after upgrade

OWASP · Feb 18, 2025 · f87bc00 · f87bc00
1 parent ba01daf
commit f87bc00
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/application/worker.py b/application/worker.py
@@ -1,4 +1,4 @@
-from rq import Worker, Queue, Connection
+from rq import Worker, Queue
 import logging
 from application.utils import redis
 
@@ -8,9 +8,7 @@
 
 listen = ["high", "default", "low"]
 
-
 def start_worker():
     logger.info(f"Worker Starting")
-    with Connection(redis.connect()):
-        worker = Worker(map(Queue, listen))
-        worker.work()
+    worker = Worker(listen,connection=redis.connect())
+    worker.work()