From 2d3741e315100a7efa599df528b912c5c376fc1f Mon Sep 17 00:00:00 2001 From: losyme Date: Sat, 20 Nov 2021 22:45:11 +0100 Subject: [PATCH] =?UTF-8?q?En=20cours=20de=20d=C3=A9veloppement?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- workers/worker.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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())