diff options
Diffstat (limited to 'restful_server')
| -rw-r--r-- | restful_server/qtip_server.py | 8 | ||||
| -rw-r--r-- | restful_server/result_handler.py | 2 |
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 |