diff --git a/core/task.go b/core/task.go index 25c6e58..87ffd81 100644 --- a/core/task.go +++ b/core/task.go @@ -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)) diff --git a/main.go b/main.go index 172c7e8..d57b9a5 100644 --- a/main.go +++ b/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