better worker removal mechanism

1 files changed, 4 insertions, 0 deletions

diff --git a/worker.go b/worker.go
index d476b918..fb55eb57 100644
--- a/worker.go
+++ b/worker.go
@@ -193,6 +193,10 @@ func (w *Worker) Exec(rqs *Payload) (rsp *Payload, err error) {
 	return rsp, err
 }
 
+func (w *Worker) markDisabled() {
+	w.state.set(StateDisabled)
+}
+
 func (w *Worker) start() error {
 	if err := w.cmd.Start(); err != nil {
 		close(w.waitDone)