pkg/timerx
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

处理没有traceid的BUG

Browse Source
This commit is contained in:
Yun
2025-04-02 20:26:27 +08:00
parent b5e3b6088b
commit c14d65c46a
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cluster.go
+1 -1
View File
@@ -448,7 +448,7 @@ func (c *Cluster) doTask(ctx context.Context, taskId string) {
} }
}() }()
ctx = context.WithValue(ctx, "trace_id", uuid.NewV4().String) ctx = context.WithValue(ctx, "trace_id", uuid.NewV4().String())
// 执行任务 // 执行任务
t.Callback(ctx, t.ExtendData) t.Callback(ctx, t.ExtendData)
single.go
+1 -1
View File
@@ -288,7 +288,7 @@ func (s *Single) doTask(ctx context.Context, call func(ctx context.Context, exte
} }
}() }()
ctx = context.WithValue(ctx, "trace_id", uuid.NewV4().String) ctx = context.WithValue(ctx, "trace_id", uuid.NewV4().String())
return call(ctx, extend) return call(ctx, extend)
} }