summaryrefslogtreecommitdiffstats
path: root/restful_server
diff options
context:
space:
mode:
Diffstat (limited to 'restful_server')
-rw-r--r--restful_server/qtip_server.py8
-rw-r--r--restful_server/result_handler.py2
2 files changed, 8 insertions, 2 deletions
diff --git a/restful_server/qtip_server.py b/restful_server/qtip_server.py
index f2676595..d9dc52ad 100644
--- a/restful_server/qtip_server.py
+++ b/restful_server/qtip_server.py
@@ -13,6 +13,7 @@ import threading
from copy import copy
import db
import func.args_handler as args_handler
+import restful_server.result_handler as result_handler
app = Flask(__name__)
@@ -174,11 +175,14 @@ default is all benchmarks in suite with specified type,
args["pod_name"],
args["suite_name"],
job_id,
+ args["testdb_url"],
+ args["node_name"],
thread_stop))
db.start_thread(job_id, post_thread, thread_stop)
return {'job_id': str(job_id)}
- def thread_post(self, installer_type, benchmarks_list, pod_name, suite_name, job_id, stop_event):
+ def thread_post(self, installer_type, benchmarks_list, pod_name, suite_name,
+ job_id, testdb_url, node_name, stop_event):
for benchmark in benchmarks_list:
if db.is_job_timeout(job_id) or stop_event.is_set():
break
@@ -190,6 +194,8 @@ default is all benchmarks in suite with specified type,
benchmark))
db.update_job_result_detail(job_id, benchmark, copy(result))
db.update_benchmark_state(job_id, benchmark, 'finished')
+ if (result_handler.dump_suite_result(suite_name) and testdb_url):
+ result_handler.push_suite_result_to_db(suite_name, testdb_url, installer_type, node_name)
db.finish_job(job_id)
diff --git a/restful_server/result_handler.py b/restful_server/result_handler.py
index 059a2510..200330cb 100644
--- a/restful_server/result_handler.py
+++ b/restful_server/result_handler.py
@@ -7,7 +7,7 @@
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################
import json
-import data.ref_results.suite_result as suite_result
+import scripts.ref_results.suite_result as suite_result
import dashboard.pushtoDB as push_to_db