PowerJobException: illegal DAG about powerjob HOT 2 CLOSED

private String validateAndConvert2String(Long wfId, PEWorkflowDAG dag) { if (dag == null || !WorkflowDAGUtils.valid(dag)) { throw new PowerJobException("illegal DAG dag = " + dag); } // 注意：这里只会保存图相关的基础信息，nodeId,jobId,jobName(nodeAlias) // 其中 jobId，jobName 均以节点中的信息为准 List<Long> nodeIdList = Lists.newArrayList(); List<PEWorkflowDAG.Node> newNodes = Lists.newArrayList(); WorkflowDAG complexDag = WorkflowDAGUtils.convert(dag); for (PEWorkflowDAG.Node node : dag.getNodes()) { WorkflowNodeInfoDO nodeInfo = workflowNodeInfoRepository.findById(node.getNodeId()).orElseThrow(() -> new PowerJobException("can't find node info by id :" + node.getNodeId())); // 更新工作流 ID if (nodeInfo.getWorkflowId() == null) { nodeInfo.setWorkflowId(wfId); nodeInfo.setGmtModified(new Date()); workflowNodeInfoRepository.saveAndFlush(nodeInfo); } if (!wfId.equals(nodeInfo.getWorkflowId())) { throw new PowerJobException("can't use another workflow's node"); } nodeValidateService.complexValidate(nodeInfo, complexDag); // 只保存节点的 ID 信息，清空其他信息 newNodes.add(new PEWorkflowDAG.Node(node.getNodeId())); nodeIdList.add(node.getNodeId()); } dag.setNodes(newNodes); int deleteCount = workflowNodeInfoRepository.deleteByWorkflowIdAndIdNotIn(wfId, nodeIdList); log.warn("[WorkflowService-{}] delete {} dissociative nodes of workflow", wfId, deleteCount); return JSON.toJSONString(dag); }
saveWorkflow会判断DAG为空throw，但是TestWorkflow第一次保存DAG一定为空？

from powerjob.

没事了，测试用例一直用的 id 为1.。。。

from powerjob.