aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorFrederick Muriuki Muriithi2024-01-24 10:30:09 +0300
committerFrederick Muriuki Muriithi2024-01-24 10:30:09 +0300
commit3bde6607290bada342b53bd9263ad364c50c3d3a (patch)
treed31ad21d5e494a2d09d6b389506987c56e4db78b
parent60e6fe7fbba0f83da5d793d7ab55ff3f873fe42a (diff)
downloadgn-uploader-3bde6607290bada342b53bd9263ad364c50c3d3a.tar.gz
redis-prefix: Update "insert data" path.
-rw-r--r--qc_app/dbinsert.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/qc_app/dbinsert.py b/qc_app/dbinsert.py
index a878ff5..31e4cea 100644
--- a/qc_app/dbinsert.py
+++ b/qc_app/dbinsert.py
@@ -95,7 +95,7 @@ def select_platform():
job_id = request.form["job_id"]
with (Redis.from_url(app.config["REDIS_URL"], decode_responses=True) as rconn,
database_connection(app.config["SQL_URI"]) as conn):
- job = jobs.job(rconn, job_id)
+ job = jobs.job(rconn, jobs.jobsnamespace(), job_id)
if job:
filename = job["filename"]
filepath = f"{app.config['UPLOAD_FOLDER']}/{filename}"
@@ -383,7 +383,7 @@ def insert_data():
def insert_status(job_id: str):
"Retrieve status of data insertion."
with Redis.from_url(app.config["REDIS_URL"], decode_responses=True) as rconn:
- job = jobs.job(rconn, job_id)
+ job = jobs.job(rconn, jobs.jobsnamespace(), job_id)
if job:
job_status = job["status"]