summaryrefslogtreecommitdiffstats
path: root/docker/storperf-master
diff options
context:
space:
mode:
authorMark Beierl <mark.beierl@dell.com>2017-09-28 14:30:50 +0000
committerGerrit Code Review <gerrit@opnfv.org>2017-09-28 14:30:50 +0000
commitf38586641a6528fd0165c1146a164622853b6ac9 (patch)
treebcecfaf2abc5bb7d8bb246421617345216d2840c /docker/storperf-master
parentc0571183df86501bb626079b40a36a0d06e6e4f1 (diff)
parent551b2161cd4858699d9c8d92c10425f0870bb1b5 (diff)
Merge "Returns job id and status"
Diffstat (limited to 'docker/storperf-master')
-rw-r--r--docker/storperf-master/rest_server.py8
-rw-r--r--docker/storperf-master/storperf/test_executor.py15
2 files changed, 19 insertions, 4 deletions
diff --git a/docker/storperf-master/rest_server.py b/docker/storperf-master/rest_server.py
index 5be3fb4..7bcd650 100644
--- a/docker/storperf-master/rest_server.py
+++ b/docker/storperf-master/rest_server.py
@@ -280,11 +280,17 @@ class Job(Resource):
if metrics_type == "status":
return jsonify(storperf.fetch_job_status(workload_id))
+
else:
metrics_type = None
if request.args.get('type'):
metrics_type = request.args.get('type')
- return jsonify(storperf.fetch_all_jobs(metrics_type))
+
+ if metrics_type == "status":
+ return jsonify(storperf.fetch_job_status(workload_id))
+
+ else:
+ return jsonify(storperf.fetch_all_jobs(metrics_type))
@swagger.operation(
parameters=[
diff --git a/docker/storperf-master/storperf/test_executor.py b/docker/storperf-master/storperf/test_executor.py
index 4c2c972..629ae15 100644
--- a/docker/storperf-master/storperf/test_executor.py
+++ b/docker/storperf-master/storperf/test_executor.py
@@ -219,9 +219,18 @@ class TestExecutor(object):
if self.job_db.job_id == job_id and self._terminated is False:
status = "Running"
- result['Status'] = status
- result['Workloads'] = self.workload_status
- result['TestResultURL'] = self.result_url
+ result['Status'] = status
+ result['Workloads'] = self.workload_status
+ result['TestResultURL'] = self.result_url
+
+ else:
+ jobs = self.job_db.fetch_jobs()
+ self.logger.info("Jobs")
+ self.logger.info(jobs)
+ for job in jobs:
+ if self.job_db.job_id == job_id and self._terminated is False:
+ status = "Running"
+ result[job] = status
return result