From b11a315b0da8ce587f4f95e0f5d93ef3ae5a1f17 Mon Sep 17 00:00:00 2001 From: Jerry Yan <792602257@qq.com> Date: Sun, 13 Apr 2025 12:00:24 +0800 Subject: [PATCH] =?UTF-8?q?=E5=86=99=E9=94=99=E4=BA=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- core/task.go | 2 +- main.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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