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(-)

(limited to 'sheepdog')

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