From e3a871e023d66495574f9b096036ae6d438629fd Mon Sep 17 00:00:00 2001 From: BonfaceKilz Date: Wed, 10 Mar 2021 13:20:49 +0300 Subject: Use correct queue name in worker --- sheepdog/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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", -- cgit v1.2.3