@ -17,7 +17,7 @@ type Model interface {
type Runner interface {
Namespace() string
Run(job *jw.Job)
Run(job *jw.Job) error
}
/*
@ -86,7 +86,9 @@ func (w *worker) runJob(job *jw.Job) {
}()
w.runner.Run(job)
if err := w.runner.Run(job); err != nil {
job.Failed().SetError(err.Error())
func (w *worker) maybeRunJob() time.Duration {