refactor: absorb panics correctly

darklab8 · Aug 23, 2024 · 0d22148 · 0d22148
1 parent 97760e4
commit 0d22148
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/utils/worker/worker_temp.go b/utils/worker/worker_temp.go
@@ -106,6 +106,9 @@ func (j *TaskPool) launchWorker(worker_id worker_types.WorkerID, tasks <-chan IT
 		task_err := make(chan error, 1)
 		go func() {
 			defer func() {
+				if !j.allow_failed_tasks {
+					return
+				}
 				if r := recover(); r != nil {
 					logus.Log.Error("Recovered in doRunf", typelog.Any("panic", r))
 					task_err <- errors.New(fmt.Sprintln("task paniced", r))