issue-5 #8
@@ -234,7 +234,7 @@ func (s *Scheduler) handleRequeue(planExecutionLogID uint, taskToRequeue *models
|
|||||||
s.logger.Warnf("任务 (原始ID: %d) 已成功重新入队,并已释放计划 %d 的锁。", taskToRequeue.ID, planExecutionLogID)
|
s.logger.Warnf("任务 (原始ID: %d) 已成功重新入队,并已释放计划 %d 的锁。", taskToRequeue.ID, planExecutionLogID)
|
||||||
}
|
}
|
||||||
|
|
||||||
// processTask 处理单个任务的逻辑 (当前为占位符)
|
// processTask 处理单个任务的逻辑
|
||||||
func (s *Scheduler) processTask(claimedLog *models.TaskExecutionLog) {
|
func (s *Scheduler) processTask(claimedLog *models.TaskExecutionLog) {
|
||||||
s.logger.Warnf("开始处理任务, 日志ID: %d, 任务ID: %d, 任务名称: %s",
|
s.logger.Warnf("开始处理任务, 日志ID: %d, 任务ID: %d, 任务名称: %s",
|
||||||
claimedLog.ID, claimedLog.TaskID, claimedLog.Task.Name)
|
claimedLog.ID, claimedLog.TaskID, claimedLog.Task.Name)
|
||||||
|
|||||||
Reference in New Issue
Block a user