jinql
/
cronsun
mirror of https://github.com/shunfei/cronsun
1
0
Fork 0
Code Issues Releases Wiki Activity

Check jobs when groups updated, fix 52

pull/64/head
Doflatango 2018-02-26 17:47:18 +08:00
parent 26515e84c9
commit 815d4d16ae
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
job.go
View File

@ -308,6 +308,7 @@ func (j *JobRule) Valid() error {
return nil
}
// Note: this function did't check the job.
func GetJob(group, id string) (job *Job, err error) {
job, _, err = GetJobAndRev(group, id)
return

7
node/node.go
View File

@ -314,6 +314,13 @@ func (n *Node) groupAddNode(g *cronsun.Group) {
n.link.delGroupJob(g.ID, jid)
continue
}
if err = job.Valid(); err != nil {
log.Warnf("invalid job[%s][%s]: %s", jl.gname, jid, err.Error())
n.link.delGroupJob(g.ID, jid)
continue
}
job.Init(n.ID)
}