From b0168b2b9f4a4b27f7b7cf359fc7f67064d9fa53 Mon Sep 17 00:00:00 2001
From: Sydonian <794346190@qq.com>
Date: Fri, 20 Sep 2024 16:49:14 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 agent/internal/task/storage_load_package.go | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/agent/internal/task/storage_load_package.go b/agent/internal/task/storage_load_package.go
index 1e73919..7653499 100644
--- a/agent/internal/task/storage_load_package.go
+++ b/agent/internal/task/storage_load_package.go
@@ -47,13 +47,16 @@ func NewStorageLoadPackage(userID cdssdk.UserID, packageID cdssdk.PackageID, sto
 func (t *StorageLoadPackage) Execute(task *task.Task[TaskContext], ctx TaskContext, complete CompleteFn) {
 	startTime := time.Now()
 	log := logger.WithType[StorageLoadPackage]("Task")
-	log.Infof("begin to load package %v to %v", t.packageID, t.storageID)
+	log.WithField("TaskID", task.ID()).
+		Infof("begin to load package %v to %v", t.packageID, t.storageID)
 
 	err := t.do(task, ctx)
 	if err == nil {
-		log.Infof("loading success, cost: %v", time.Since(startTime))
+		log.WithField("TaskID", task.ID()).
+			Infof("loading success, cost: %v", time.Since(startTime))
 	} else {
-		log.Warnf("loading package: %v, cost: %v", err, time.Since(startTime))
+		log.WithField("TaskID", task.ID()).
+			Warnf("loading package: %v, cost: %v", err, time.Since(startTime))
 	}
 
 	complete(err, CompleteOption{