LumeWeb
/
portal
1
0
Fork 0
Code Issues 5 Pull Requests Packages Projects Releases Wiki Activity

fix: fix after and error functions

This commit is contained in:
Derrick Hammer 2024-02-01 18:51:05 -05:00
parent 0a6efaf0e3
commit 9330bb36bf
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cron/cron.go
View File

@ -101,14 +101,12 @@ func (c *CronServiceDefault) RetryableTask(params RetryableTaskParams) CronJob {
task := gocron.NewTask(params.Function, params.Args...) task := gocron.NewTask(params.Function, params.Args...)
afterFunc := params.After if params.After == nil {
if afterFunc == nil { params.After = func(jobID uuid.UUID, jobName string) {}
afterFunc = func(jobID uuid.UUID, jobName string) {}
} }
errorFunc := params.Error if params.Error == nil {
if errorFunc == nil { params.Error = func(jobID uuid.UUID, jobName string, err error) {}
errorFunc = func(jobID uuid.UUID, jobName string, err error) {}
} }
listeners := gocron.WithEventListeners(gocron.AfterJobRunsWithError(func(jobID uuid.UUID, jobName string, err error) { listeners := gocron.WithEventListeners(gocron.AfterJobRunsWithError(func(jobID uuid.UUID, jobName string, err error) {