|
|
@@ -20,7 +20,6 @@ from ad_monitor_util import _monitor
|
|
|
|
|
|
target_names = {
|
|
|
'样本shuffle',
|
|
|
- '评估样本重组',
|
|
|
'模型训练-样本shufle',
|
|
|
'模型训练-自定义',
|
|
|
'模型增量训练',
|
|
|
@@ -646,34 +645,8 @@ def update_online_model():
|
|
|
print(error_message)
|
|
|
raise Exception(error_message)
|
|
|
|
|
|
-def update_validation_config():
|
|
|
- try:
|
|
|
- job_dict = get_job_dict()
|
|
|
- node_dict = get_node_dict()
|
|
|
- print(node_dict)
|
|
|
- job_id = job_dict['样本shuffle']
|
|
|
- validate_job_detail = wait_job_end(job_id)
|
|
|
- table = None
|
|
|
- if validate_job_detail['Status'] == 'Succeeded':
|
|
|
- pipeline_run_id = validate_job_detail['RunId']
|
|
|
- node_id = validate_job_detail['PaiflowNodeId']
|
|
|
- flow_out_put_detail = PAIClient.get_flow_out_put(pipeline_run_id, node_id, 2)
|
|
|
- outputs = flow_out_put_detail['Outputs']
|
|
|
- for output in outputs:
|
|
|
- if output["Producer"] == node_dict['评估样本重组'] and output["Name"] == "outputTable":
|
|
|
- value1 = json.loads(output["Info"]['value'])
|
|
|
- table = value1['location']['table']
|
|
|
- if not table:
|
|
|
- raise Exception("table not available")
|
|
|
- update_global_param({'eval_table_name': table})
|
|
|
- except Exception as e:
|
|
|
- error_message = f"在执行 update_validation_config 函数时发生异常: {str(e)}"
|
|
|
- print(error_message)
|
|
|
- raise Exception(error_message)
|
|
|
-
|
|
|
@retry
|
|
|
def get_validate_model_data():
|
|
|
- update_validation_config()
|
|
|
try:
|
|
|
node_dict = get_node_dict()
|
|
|
train_node_id = node_dict['虚拟起始节点']
|
xueyiming