chore: do not delete the last worker

Signed-off-by: Valery Piashchynski <piashchynski.valery@gmail.com>
roadrunner-server · Jun 25, 2024 · 82e59c0 · 82e59c0
1 parent f4ca750
commit 82e59c0
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/worker_watcher/worker_watcher.go b/worker_watcher/worker_watcher.go
@@ -80,6 +80,12 @@ func (ww *WorkerWatcher) RemoveWorker(ctx context.Context) error {
  return err
  }
 
+ // can't remove the last worker
+ if atomic.LoadUint64(&ww.numWorkers) == 1 {
+ ww.log.Warn("can't remove the last worker", zap.Int64("pid", w.Pid()))
+ return nil
+ }
+
  // destroy and stop
  w.State().Transition(fsm.StateDestroyed)
  _ = w.Stop()