Update scripts to use redis prefix.

1 files changed, 4 insertions, 2 deletions

diff --git a/scripts/rqtl2/entry.py b/scripts/rqtl2/entry.py
index eccc19d..93fc130 100644
--- a/scripts/rqtl2/entry.py
+++ b/scripts/rqtl2/entry.py
@@ -6,6 +6,7 @@ from argparse import Namespace
 from redis import Redis
 from MySQLdb import Connection
 
+from qc_app import jobs
 from qc_app.db_utils import database_connection
 from qc_app.check_connections import check_db, check_redis
 
@@ -25,10 +26,11 @@ def build_main(args: Namespace,
 
         with (Redis.from_url(args.redisuri, decode_responses=True) as rconn,
               database_connection(args.databaseuri) as dbconn):
+            fqjobid = jobs.job_key(jobs.jobsnamespace(), args.jobid)
             logger.addHandler(setup_redis_logger(
                 rconn,
-                args.jobid,
-                f"{str(args.jobid)}:log-messages",
+                fqjobid,
+                f"{fqjobid}:log-messages",
                 args.redisexpiry))
             logger.setLevel(loglevel)
             return run_fn(dbconn, args)