fixing tests

1 files changed, 4 insertions, 0 deletions

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