add tag of execution_id into DAGOperations.finishTaskSync trace

weibocom · Jan 8, 2025 · c240c82 · c240c82
1 parent 66bf685
commit c240c82
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...icene-traversal/src/main/java/com/weibo/rill/flow/olympicene/traversal/DAGOperations.java b/...icene-traversal/src/main/java/com/weibo/rill/flow/olympicene/traversal/DAGOperations.java
@@ -196,6 +196,7 @@ public void finishTaskAsync(String executionId, String taskCategory, NotifyInfo
 
     @Trace(operationName = "DAGOperations.finishTaskSync")
     public void finishTaskSync(String executionId, String taskCategory, NotifyInfo notifyInfo, Map<String, Object> output) {
+        ActiveSpan.tag("executionId", executionId);
         ActiveSpan.tag("taskName", notifyInfo.getTaskInfoName());
         ActiveSpan.tag("taskCategory", taskCategory);
         log.info("finishTask task begin to execute executionId:{} notifyInfo:{}", executionId, notifyInfo);