解决调试发现的问题

executor/internal/task/pcm_schedule_task.go

@@ -40,6 +40,8 @@ func (t *PCMSubmitTask) Execute(task *task.Task[TaskContext], ctx TaskContext, c
 }
 
 func (t *PCMSubmitTask) do(taskID string, ctx TaskContext) error {
+	log := logger.WithType[PCMSubmitTask]("Task")
+
 	pcmCli, err := schglb.PCMPool.Acquire()
 	if err != nil {
 		return fmt.Errorf("new pcm client: %w", err)
@@ -59,14 +61,21 @@ func (t *PCMSubmitTask) do(taskID string, ctx TaskContext) error {
 		return err
 	}
 
+	log.Infof("pcm submit task success, task id: %v", resp.TaskID)
+
 	var prevStatus pcmsdk.TaskStatus
+	retryCount := 0
 	for {
 		tsResp, err := pcmCli.GetTask(pcmsdk.GetTaskReq{
 			PartID: t.PCMParticipantID,
 			TaskID: resp.TaskID,
 		})
 		if err != nil {
-			return err
+			retryCount++
+			if retryCount > 3 {
+				return err
+			}
+			continue
 		}
 
 		if tsResp.TaskStatus != prevStatus {

executor/internal/task/storage_load_package.go

@@ -23,7 +23,7 @@ func NewStorageLoadPackage(info *exectsk.StorageLoadPackage) *StorageLoadPackage
 
 func (t *StorageLoadPackage) Execute(task *task.Task[TaskContext], ctx TaskContext, complete CompleteFn) {
 	log := logger.WithType[StorageLoadPackage]("Task")
-	log.Debugf("begin with %w", logger.FormatStruct(t.StorageLoadPackage))
+	log.Debugf("begin with %v", logger.FormatStruct(t.StorageLoadPackage))
 	defer log.Debugf("end")
 
 	packagePath, err := t.do(ctx)