Add custom redis queue worker

programminghistorian · Aug 25, 2019 · 9a2b43c · 9a2b43c
1 parent b4ec19c
commit 9a2b43c
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/worker.py b/worker.py
@@ -0,0 +1,13 @@
+#!/usr/bin/env python
+import sys
+
+from redis import Redis
+from rq import Connection, Worker
+
+# Provide queue names to listen to as arguments to this script,
+# similar to rq worker
+with Connection():
+ qs = sys.argv[1:] or ["default"]
+
+ w = Worker(qs, connection=Redis(host="redis"))
+ w.work()