调整链路实现

farseer-go · Nov 30, 2024 · 4e23751 · 4e23751
1 parent 491c10c
commit 4e23751
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/invokeJob.go b/invokeJob.go
@@ -68,7 +68,7 @@ func invokeJob(clientVO ClientVO, task taskDTO) {
 
 	// 链路追踪
 	entryFSchedule := jobContext.traceManager.EntryFSchedule(jobContext.Name, jobContext.Id, jobContext.Data.ToMap())
-	defer entryFSchedule.End(nil)
+	defer container.Resolve[trace.IManager]().Push(entryFSchedule, nil)
 
 	// 执行任务并拿到结果
 	exception.Try(func() {