openharmony/testfwk_xdevice
1
0
Fork 0
mirror of https://gitee.com/openharmony/testfwk_xdevice synced 2024-11-23 07:20:44 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

增加任务下发和结果上传代码功能

Browse Source
This commit is contained in:
alex_hold 2021-06-15 16:24:36 +08:00 committed by Gitee
parent 5159e6c932
commit 2d11033c2a
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/xdevice/_core/executor/scheduler.py
View File

@ -84,6 +84,7 @@ class Scheduler(object):
task_type = ""
task_name = ""
mode = ""
proxy = None
# command_queue to store test commands
command_queue = []
@ -789,6 +790,10 @@ class Scheduler(object):
LOG.info(
"get upload params: %s, %s, %s, %s, %s, %s" % (
case_id, result, error, start_time, end_time, report_path))
if Scheduler.proxy:
Scheduler.proxy.upload_result(case_id, result, error,
start_time, end_time, report_path)
return
from agent.factory import upload_result
upload_result(case_id, result, error, start_time, end_time,
report_path)
@ -814,7 +819,6 @@ class Scheduler(object):
error_no="00201")
return
LOG.info("need upload %s case" % len(upload_params))
from agent.factory import upload_batch
upload_suite = []
for upload_param in upload_params:
case_id, result, error, start_time, end_time, report_path = \
@ -824,6 +828,11 @@ class Scheduler(object):
"report": report_path}
LOG.info("case info: %s", case)
upload_suite.append(case)
if Scheduler.proxy:
Scheduler.proxy.upload_result(case_id, result, error,
start_time, end_time, report_path)
return
from agent.factory import upload_batch
upload_batch(upload_suite)
@classmethod