From e0acef9ced9d1170a3341e30662b4521f65befa6 Mon Sep 17 00:00:00 2001
From: Frederick Muriuki Muriithi
Date: Tue, 8 Apr 2025 12:59:09 -0500
Subject: Use computed job queue to avoid collisions.

---
 gn3/api/correlation.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

(limited to 'gn3/api/correlation.py')

diff --git a/gn3/api/correlation.py b/gn3/api/correlation.py
index c77dd93..915978e 100644
--- a/gn3/api/correlation.py
+++ b/gn3/api/correlation.py
@@ -12,10 +12,11 @@ from gn3.settings import SQL_URI
 from gn3.db_utils import database_connection
 from gn3.commands import run_sample_corr_cmd
 from gn3.responses.pcorrs_responses import build_response
-from gn3.commands import run_async_cmd, compose_pcorrs_command
 from gn3.computations.correlations import map_shared_keys_to_values
 from gn3.computations.correlations import compute_tissue_correlation
 from gn3.computations.correlations import compute_all_lit_correlation
+from gn3.commands import (
+    run_async_cmd, compute_job_queue, compose_pcorrs_command)
 
 correlation = Blueprint("correlation", __name__)
 
@@ -139,7 +140,7 @@ def partial_correlation():
         queueing_results = run_async_cmd(
                 conn=conn,
                 cmd=command,
-                job_queue=current_app.config.get("REDIS_JOB_QUEUE"),
+                job_queue=compute_job_queue(current_app),
                 env = {"PYTHONPATH": ":".join(sys.path), "SQL_URI": SQL_URI})
         return build_response({
             "status": "success",
-- 
cgit 1.4.1