diff --git a/internal/app/service/task/scheduler.go b/internal/app/service/task/scheduler.go index fc9506e..caa135e 100644 --- a/internal/app/service/task/scheduler.go +++ b/internal/app/service/task/scheduler.go @@ -209,8 +209,8 @@ func (s *Scheduler) handleRequeue(planExecutionLogID uint, taskToRequeue *models // processTask 处理单个任务的逻辑 func (s *Scheduler) processTask(claimedLog *models.TaskExecutionLog) { - s.logger.Warnf("开始处理任务, 日志ID: %d, 任务ID: %d, 任务名称: %s", - claimedLog.ID, claimedLog.TaskID, claimedLog.Task.Name) + s.logger.Warnf("开始处理任务, 日志ID: %d, 任务ID: %d, 任务名称: %s, 描述: %s", + claimedLog.ID, claimedLog.TaskID, claimedLog.Task.Name, claimedLog.Task.Description) claimedLog.StartedAt = time.Now() claimedLog.Status = models.ExecutionStatusCompleted // 先乐观假定任务成功, 后续失败了再改 @@ -441,8 +441,8 @@ func (s *Scheduler) handlePlanCompletion(planLogID uint) { if newStatus == models.PlanStatusEnabled { if err := s.analysisPlanTaskManager.CreateOrUpdateTrigger(topLevelPlanID); err != nil { s.logger.Errorf("为计划 %d 创建/更新触发器失败: %v", topLevelPlanID, err) - } else { - s.logger.Infof("计划 %d 状态为 '%d',无需创建下一次触发器。", topLevelPlanID, newStatus) } + } else { + s.logger.Infof("计划 %d 状态为 '%d',无需创建下一次触发器。", topLevelPlanID, newStatus) } }