From 2390c945478ad2bb00ab73ea98aad50a42d64f0b Mon Sep 17 00:00:00 2001 From: Wolfy-J Date: Sun, 28 Jan 2018 15:44:18 +0300 Subject: stop by worker --- pool.go | 1 + 1 file changed, 1 insertion(+) (limited to 'pool.go') diff --git a/pool.go b/pool.go index 7abfe7b2..4c9f0b26 100644 --- a/pool.go +++ b/pool.go @@ -95,6 +95,7 @@ func (p *Pool) Exec(rqs *Payload) (rsp *Payload, err error) { return nil, errors.Wrap(err, "unable to allocate worker") } + //todo: timeout rsp, err = w.Exec(rqs) if err != nil { -- cgit v1.2.3