rogee/atomctl
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: job cancel id

Browse Source
This commit is contained in:
rogeecn
2025-03-21 17:02:17 +08:00
parent b83d36f917
commit e51acee8d8
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
templates/project/providers/job/provider.go.tpl
View File

@@ -159,7 +159,7 @@ func (q *Job) AddPeriodicJob(job contracts.CronJobArg) error {
return nil return nil
} }
func (q *Job) Cancel(kind string) error { func (q *Job) Cancel(id string) error {
client, err := q.Client() client, err := q.Client()
if err != nil { if err != nil {
return err return err
@@ -168,18 +168,18 @@ func (q *Job) Cancel(kind string) error {
q.l.Lock() q.l.Lock()
defer q.l.Unlock() defer q.l.Unlock()
if h, ok := q.periodicJobs[kind]; ok { if h, ok := q.periodicJobs[id]; ok {
client.PeriodicJobs().Remove(h) client.PeriodicJobs().Remove(h)
delete(q.periodicJobs, kind) delete(q.periodicJobs, id)
return nil return nil
} }
if r, ok := q.jobs[kind]; ok { if r, ok := q.jobs[id]; ok {
_, err = client.JobCancel(q.ctx, r.Job.ID) _, err = client.JobCancel(q.ctx, r.Job.ID)
if err != nil { if err != nil {
return err return err
} }
delete(q.jobs, kind) delete(q.jobs, id)
return nil return nil
} }