mirror of
https://github.com/PowerJob/PowerJob.git
synced 2025-07-17 00:00:04 +08:00
fix: NPE when fetch workflow info
This commit is contained in:
parent
84d00ee580
commit
540849524d
@ -266,13 +266,14 @@ public class WorkflowService {
|
|||||||
|
|
||||||
WorkflowInfoVO res = WorkflowInfoVO.from(wfInfo);
|
WorkflowInfoVO res = WorkflowInfoVO.from(wfInfo);
|
||||||
|
|
||||||
PEWorkflowDAG dagInfo;
|
PEWorkflowDAG dagInfo = null;
|
||||||
try {
|
try {
|
||||||
dagInfo = JSON.parseObject(wfInfo.getPeDAG(), PEWorkflowDAG.class);
|
dagInfo = JSON.parseObject(wfInfo.getPeDAG(), PEWorkflowDAG.class);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.warn("[WorkflowService-{}]illegal DAG : {}", wfInfo.getId(), wfInfo.getPeDAG());
|
log.warn("[WorkflowService-{}]illegal DAG : {}", wfInfo.getId(), wfInfo.getPeDAG());
|
||||||
// 这里直接返回空对象
|
}
|
||||||
res.setPEWorkflowDAG(new PEWorkflowDAG());
|
if (dagInfo == null) {
|
||||||
|
// 这里直接返回
|
||||||
return res;
|
return res;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user