toolchaintechnologycenter/spdm-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改：工作流对接，任务提交参数优化

Browse Source
This commit is contained in:
yangyang01000846
2025-12-03 13:44:53 +08:00
parent 3ec5d77eda
commit c32eafbf1d
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
flowable/src/main/java/com/sdm/flowable/delegate/handler/HpcHandler.java
View File

@@ -29,15 +29,14 @@ public class HpcHandler implements ExecutionHandler<SubmitHpcTaskRemoteReq,HPCEx
@Override
public void execute(DelegateExecution execution, SubmitHpcTaskRemoteReq params, HPCExecuteConfig config) {
String beforeNodeId = config.getBeforeNodeId();
params.setBeforeNodeId(config.getBeforeNodeId());
// 实现HPC处理逻辑...
// INIT(初始化)/RUNNING(执行中)/SUCCESS(执行成功)/FAIL(执行失败)
String status = "INIT";
// 1. 调用 HPC 平台提交任务
SubmitHpcTaskRemoteReq mockReq = mockSubmitHpcTaskReq();
SdmResponse<String> submitResp = taskFeignClient.submitHpcJob(mockReq);
SdmResponse<String> submitResp = taskFeignClient.submitHpcJob(params);
if(!submitResp.isSuccess()|| StringUtils.isBlank(submitResp.getData())){
log.error("HpcHandler submit failed,jobName:{}",mockReq.getJobName());
log.error("HpcHandler submit failed,jobName:{}",params);
status = "FAIL";
}
String hpcTaskId = submitResp.getData();