throw exception when get.json can not fonud dag

weibocom · Dec 5, 2024 · 9738ce7 · 9738ce7
1 parent 28fd470
commit 9738ce7
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/rill-flow-service/src/main/java/com/weibo/rill/flow/service/facade/DAGRuntimeFacade.java b/rill-flow-service/src/main/java/com/weibo/rill/flow/service/facade/DAGRuntimeFacade.java
@@ -235,6 +235,10 @@ public Map<String, Object> getBasicDAGInfo(String executionId, boolean brief) {
             dagInfo = longTermStorage.getBasicDAGInfo(executionId);
         }
 
+        if (dagInfo == null) {
+            throw new IllegalArgumentException("dag is not found");
+        }
+
         Map<String, Object> result = makeDAGInfoMap(dagInfo, brief);
         result.put("context", getContext(executionId, null));
         result.put("invoke_summary", tenantTaskStatistic.getFlowAggregate(executionId));