aboutsummaryrefslogtreecommitdiff
path: root/qc_app/samples.py
diff options
context:
space:
mode:
Diffstat (limited to 'qc_app/samples.py')
-rw-r--r--qc_app/samples.py7
1 files changed, 5 insertions, 2 deletions
diff --git a/qc_app/samples.py b/qc_app/samples.py
index bf33715..cf97b8d 100644
--- a/qc_app/samples.py
+++ b/qc_app/samples.py
@@ -240,6 +240,7 @@ def upload_samples():
the_job = jobs.launch_job(
jobs.initialise_job(
rconn,
+ jobs.jobsnamespace(),
str(uuid.uuid4()),
build_sample_upload_job(
species["SpeciesId"],
@@ -259,7 +260,8 @@ def upload_samples():
@samples.route("/upload/status/<uuid:job_id>", methods=["GET"])
def upload_status(job_id: uuid.UUID):
"""Check on the status of a samples upload job."""
- job = with_redis_connection(lambda rconn: jobs.job(rconn, str(job_id)))
+ job = with_redis_connection(lambda rconn: jobs.job(
+ rconn, jobs.jobsnamespace(), job_id))
if job:
status = job["status"]
if status == "success":
@@ -285,7 +287,8 @@ def upload_status(job_id: uuid.UUID):
@samples.route("/upload/failure/<uuid:job_id>", methods=["GET"])
def upload_failure(job_id: uuid.UUID):
"""Display the errors of the samples upload failure."""
- job = with_redis_connection(lambda rconn: jobs.job(rconn, str(job_id)))
+ job = with_redis_connection(lambda rconn: jobs.job(
+ rconn, jobs.jobsnamespace(), job_id))
if not bool(job):
return render_template("no_such_job.html", job_id=job_id), 400