aboutsummaryrefslogtreecommitdiff
path: root/sheepdog/worker.py
diff options
context:
space:
mode:
authorBonfaceKilz2021-03-10 13:20:49 +0300
committerBonfaceKilz2021-03-10 13:20:49 +0300
commite3a871e023d66495574f9b096036ae6d438629fd (patch)
tree3a289b41a228cdce7b68a2acd45de6c9c135c6d5 /sheepdog/worker.py
parentea9f2d5716c53fd35a7fb318e76a5da73cb32a3c (diff)
downloadgenenetwork3-e3a871e023d66495574f9b096036ae6d438629fd.tar.gz
Use correct queue name in worker
Diffstat (limited to 'sheepdog/worker.py')
-rw-r--r--sheepdog/worker.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/sheepdog/worker.py b/sheepdog/worker.py
index b5681ce..403f944 100644
--- a/sheepdog/worker.py
+++ b/sheepdog/worker.py
@@ -16,7 +16,7 @@ def run_jobs(conn):
"""Process the redis using a redis connection, CONN"""
# pylint: disable=E0401, C0415
from gn3.commands import run_cmd
- cmd_id = str(conn.lpop("GN2::job-queue"))
+ cmd_id = str(conn.lpop("GN3::job-queue"))
if bool(cmd_id):
cmd = conn.hget("cmd", cmd_id)
if cmd and (str(conn.hget(cmd, "status")) not in ["success",