diff --git a/workers/worker.go b/workers/worker.go index 0228d04..247536e 100644 --- a/workers/worker.go +++ b/workers/worker.go @@ -57,11 +57,15 @@ func (w *worker) cloneLogger(job *jw.Job) (Logger, error) { return w.logger.Clone(id, name) } -func (w *worker) maybeRunJob() time.Duration { +func (w *worker) maybeRunJob() (duration time.Duration) { defer func() { if data := recover(); data != nil { w.logger.Fatal("PANIC ERROR RECOVERED", "data", data) //:::::::::::::::::::::::::::::::::::::::::::::::::::: } + + duration = 5 * time.Second + + w.stop() }() job, err := w.runner.Model().NextJob(w.runner.Namespace())