Supervised pool

1 files changed, 2 insertions, 3 deletions

diff --git a/pipe_factory.go b/pipe_factory.go
index a6c94614..807d7793 100755
--- a/pipe_factory.go
+++ b/pipe_factory.go
@@ -84,7 +84,7 @@ func (f *PipeFactory) SpawnWorkerWithContext(ctx context.Context, cmd *exec.Cmd)
 			}
 
 			// todo kill timeout
-			errK := w.Kill(ctx)
+			errK := w.Kill()
 			if errK != nil {
 				errs = append(errs, fmt.Errorf("error killing the worker with PID number %d, Created: %s", w.Pid(), w.Created()).Error())
 			}
@@ -164,8 +164,7 @@ func (f *PipeFactory) SpawnWorker(cmd *exec.Cmd) (WorkerBase, error) {
 			errs = append(errs, errF.Error())
 		}
 
-		// todo kill timeout ??
-		errK := w.Kill(context.Background())
+		errK := w.Kill()
 		if errK != nil {
 			errs = append(errs, fmt.Errorf("error killing the worker with PID number %d, Created: %s", w.Pid(), w.Created()).Error())
 		}