En cours de développement

workers/worker.go

@@ -61,11 +61,11 @@ 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
+			duration = 5 * time.Second
 
-		w.stop()
+			w.stop()
+		}
 	}()
 
 	job, err := w.runner.Model().NextJob(w.runner.Namespace())