diff options
| author | Valery Piashchynski <[email protected]> | 2021-06-25 22:07:52 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-06-25 22:07:52 +0300 |
| commit | ae58af3ca1d37cb61f106146e4bf9bd1d033e8b3 (patch) | |
| tree | 8d14a41607080298e1f0441a9ad620aee17da39e /pkg/pool/supervisor_test.go | |
| parent | e9249c7896331bab97a18a7ee0db17803fdd31fb (diff) | |
- Fix bug with an exec_ttl reallocation issue
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pkg/pool/supervisor_test.go')
| -rw-r--r-- | pkg/pool/supervisor_test.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/pkg/pool/supervisor_test.go b/pkg/pool/supervisor_test.go index dc307c33..f371b925 100644 --- a/pkg/pool/supervisor_test.go +++ b/pkg/pool/supervisor_test.go @@ -108,7 +108,7 @@ func TestSupervisedPool_ExecTTL_TimedOut(t *testing.T) { pid := p.Workers()[0].Pid() - resp, err := p.execWithTTL(context.Background(), payload.Payload{ + resp, err := p.Exec(payload.Payload{ Context: []byte(""), Body: []byte("foo"), }) @@ -148,7 +148,7 @@ func TestSupervisedPool_Idle(t *testing.T) { pid := p.Workers()[0].Pid() - resp, err := p.execWithTTL(context.Background(), payload.Payload{ + resp, err := p.Exec(payload.Payload{ Context: []byte(""), Body: []byte("foo"), }) @@ -160,7 +160,7 @@ func TestSupervisedPool_Idle(t *testing.T) { time.Sleep(time.Second * 5) // worker should be marked as invalid and reallocated - _, err = p.execWithTTL(context.Background(), payload.Payload{ + _, err = p.Exec(payload.Payload{ Context: []byte(""), Body: []byte("foo"), }) |