修改报警

ad/pai_flow_operator2.py

@@ -724,6 +724,9 @@ if __name__ == '__main__':
     for func in functions[start_index:]:
         if not func():
             print(f"{func.__name__} 执行失败，后续函数不再执行。")
+            step_end_time = int(time.time())
+            elapsed = step_end_time - start_time
+            _monitor('error', f"DNN模型更新，{func.__name__} 执行失败，后续函数不再执行，请检查", start_time, elapsed, None)
             break
     else:
         print("所有函数都成功执行，可以继续下一步操作。")