add err check for task running

This commit is contained in:
Jason li 2021-01-15 11:35:10 +08:00
parent 9516caa32a
commit 09f349f716

View File

@ -555,10 +555,18 @@ func runNextTasks(sortList *MapSorter, effective time.Time) {
go func(e Tasker) {
ctx, cancelFunc := context.WithTimeout(ctx, duration)
defer cancelFunc()
e.Run(ctx)
err := e.Run(ctx)
if err != nil {
log.Printf("tasker.run err: %s\n", err.Error())
}
}(e)
} else {
go e.Run(ctx)
go func(e Tasker) {
err := e.Run(ctx)
if err != nil {
log.Printf("tasker.run err: %s\n", err.Error())
}
}(e)
}
e.SetPrev(context.Background(), e.GetNext(context.Background()))