From a80abffc2618a015723389fe1831e0a5d37f60ba Mon Sep 17 00:00:00 2001 From: joelei Date: Sat, 20 Dec 2025 00:49:24 +0800 Subject: [PATCH] add new uuid --- task/manager.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/task/manager.go b/task/manager.go index 68f23a0..a928eba 100644 --- a/task/manager.go +++ b/task/manager.go @@ -29,6 +29,7 @@ import ( "github.com/RichardKnop/machinery/v2/log" "github.com/RichardKnop/machinery/v2/tasks" "github.com/RichardKnop/machinery/v2/utils" + "github.com/google/uuid" "github.com/robfig/cron/v3" irevoker "git.ifooth.com/common/pkg/task/revokers/iface" @@ -290,6 +291,8 @@ func (m *TaskManager) registerScheduleTask(spec string, task *types.Task) error return } + // 定时任务每次生成新的任务ID + task.TaskID = uuid.NewString() err = m.Dispatch(task) if err != nil { log.ERROR.Printf("periodic task failed. task name is: %s. error is %s", task.TaskName, err.Error())