diff options
| author |   zhifeng.jiang <jiang.zhifeng@zte.com.cn> | 2016-10-13 23:43:31 +0800 |
|---|---|---|
| committer | zhifeng.jiang <jiang.zhifeng@zte.com.cn> | 2016-10-20 22:41:26 +0800 |
| commit | 6a0eaa8c0b7bd74261a43e805e7d8cd8498e7845 (patch) | |
| tree | 2f841c16968edf63a3593d2e0cea4b0d48712fa9 /restful_server/qtip_server.py | |
| parent | 00928695ecae5e7565bc82d22bb807d2603a6d98 (diff) | |
Push test results to testdb at the end of qtip_server job.
JIRA:QTIP-99
Change-Id: I2a3ba25c1bcb66cf71a65757c3f003838dca614f
Signed-off-by: zhifeng.jiang <jiang.zhifeng@zte.com.cn>
Diffstat (limited to 'restful_server/qtip_server.py')
| -rw-r--r-- | restful_server/qtip_server.py | 8 |
1 files changed, 7 insertions, 1 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) |