Skip to content

Commit eb8ceba

Browse files
committed
fix: 批量编辑抛异常后解锁工作流 #AI commit#
1 parent 153408e commit eb8ceba

1 file changed

Lines changed: 8 additions & 1 deletion

File tree

  • dss-orchestrator/orchestrators/dss-workflow/dss-workflow-server/src/main/java/com/webank/wedatasphere/dss/workflow/service/impl

dss-orchestrator/orchestrators/dss-workflow/dss-workflow-server/src/main/java/com/webank/wedatasphere/dss/workflow/service/impl/DSSFlowServiceImpl.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2543,7 +2543,14 @@ public void batchEditFlow(BatchEditFlowRequest batchEditFlowRequest, String tick
25432543
editFlowRequestTOFlowIDMap.get(targetFlowId) : new ArrayList<>();
25442544

25452545
// 校验 tableau/tableauDataRefre 节点的 viewId/datasourceId
2546-
validateTableauNode(editFlowRequest, nodeContentByContentId, targetFlowId, workspace, userName);
2546+
try{
2547+
validateTableauNode(editFlowRequest, nodeContentByContentId, targetFlowId, workspace, userName);
2548+
}catch (Exception e){
2549+
logger.error("user is {}, node is {} validateTableauNode error msg is {}",userName,editFlowRequest.getTitle()
2550+
,e.getMessage(),e);
2551+
workFlowManager.unlockWorkflow(userName, flowId, true, workspace);
2552+
throw e;
2553+
}
25472554

25482555
// 处理starrocks节点
25492556
if ("linkis.jdbc.starrocks".equals(nodeContentByContentId.getJobType())) {

0 commit comments

Comments
 (0)