diff options
author | BonfaceKilz | 2021-03-10 13:20:49 +0300 |
---|---|---|
committer | BonfaceKilz | 2021-03-10 13:20:49 +0300 |
commit | e3a871e023d66495574f9b096036ae6d438629fd (patch) | |
tree | 3a289b41a228cdce7b68a2acd45de6c9c135c6d5 | |
parent | ea9f2d5716c53fd35a7fb318e76a5da73cb32a3c (diff) | |
download | genenetwork3-e3a871e023d66495574f9b096036ae6d438629fd.tar.gz |
Use correct queue name in worker
-rw-r--r-- | sheepdog/worker.py | 2 |
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", |