diff options
author | Frederick Muriuki Muriithi | 2024-01-24 10:30:09 +0300 |
---|---|---|
committer | Frederick Muriuki Muriithi | 2024-01-24 10:30:09 +0300 |
commit | 3bde6607290bada342b53bd9263ad364c50c3d3a (patch) | |
tree | d31ad21d5e494a2d09d6b389506987c56e4db78b /qc_app | |
parent | 60e6fe7fbba0f83da5d793d7ab55ff3f873fe42a (diff) | |
download | gn-uploader-3bde6607290bada342b53bd9263ad364c50c3d3a.tar.gz |
redis-prefix: Update "insert data" path.
Diffstat (limited to 'qc_app')
-rw-r--r-- | qc_app/dbinsert.py | 4 |
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"] |