From e51acee8d8e9286d0a0dce9a14aa40deb6bf1395 Mon Sep 17 00:00:00 2001 From: rogeecn Date: Fri, 21 Mar 2025 17:02:17 +0800 Subject: [PATCH] fix: job cancel id --- templates/project/providers/job/provider.go.tpl | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/templates/project/providers/job/provider.go.tpl b/templates/project/providers/job/provider.go.tpl index 0aadd3f..25c3331 100644 --- a/templates/project/providers/job/provider.go.tpl +++ b/templates/project/providers/job/provider.go.tpl @@ -159,7 +159,7 @@ func (q *Job) AddPeriodicJob(job contracts.CronJobArg) error { return nil } -func (q *Job) Cancel(kind string) error { +func (q *Job) Cancel(id string) error { client, err := q.Client() if err != nil { return err @@ -168,18 +168,18 @@ func (q *Job) Cancel(kind string) error { q.l.Lock() defer q.l.Unlock() - if h, ok := q.periodicJobs[kind]; ok { + if h, ok := q.periodicJobs[id]; ok { client.PeriodicJobs().Remove(h) - delete(q.periodicJobs, kind) + delete(q.periodicJobs, id) return nil } - if r, ok := q.jobs[kind]; ok { + if r, ok := q.jobs[id]; ok { _, err = client.JobCancel(q.ctx, r.Job.ID) if err != nil { return err } - delete(q.jobs, kind) + delete(q.jobs, id) return nil }