写错了
This commit is contained in:
parent
91bb5e4e5a
commit
b11a315b0d
@ -18,7 +18,7 @@ import (
|
||||
var tracer = otel.Tracer("task")
|
||||
|
||||
func HandleTask(ctx context.Context, device config.DeviceMapping, task dto.Task) (*dto.FileObject, error) {
|
||||
subCtx, span := tracer.Start(ctx, "startTask")
|
||||
subCtx, span := tracer.Start(ctx, "HandleTask")
|
||||
defer span.End()
|
||||
adapter := fs.GetAdapter()
|
||||
span.SetAttributes(attribute.String("taskId", task.TaskID))
|
||||
|
2
main.go
2
main.go
@ -42,7 +42,7 @@ func startTask(device config.DeviceMapping, task dto.Task) {
|
||||
return
|
||||
}
|
||||
result := api.ReportTaskSuccess(ctx, task.TaskID, fo)
|
||||
if result {
|
||||
if !result {
|
||||
span.SetStatus(codes.Error, "上报任务成功失败")
|
||||
log.Printf("上报任务成功失败, TaskID:【%s】, DeviceNo: %s, 错误: %v\n", task.TaskID, task.DeviceNo, err)
|
||||
return
|
||||
|
Loading…
x
Reference in New Issue
Block a user