summaryrefslogtreecommitdiff
path: root/pkg/pool/static_pool_test.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-01-18 22:38:45 +0300
committerValery Piashchynski <[email protected]>2021-01-18 22:38:45 +0300
commit4b17b4e3050be2f9caef749e7f05394d46815459 (patch)
tree787504dbb7b570f39c12af2913187175042b4bfd /pkg/pool/static_pool_test.go
parent6cbf6d78fe0a49475e5523a2bffe8996ecf8396e (diff)
Update CI
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pkg/pool/static_pool_test.go')
-rwxr-xr-xpkg/pool/static_pool_test.go7
1 files changed, 3 insertions, 4 deletions
diff --git a/pkg/pool/static_pool_test.go b/pkg/pool/static_pool_test.go
index 53d6b191..f66895dc 100755
--- a/pkg/pool/static_pool_test.go
+++ b/pkg/pool/static_pool_test.go
@@ -459,16 +459,15 @@ func Test_Static_Pool_Handle_Dead(t *testing.T) {
},
)
assert.NoError(t, err)
- defer p.Destroy(ctx)
-
assert.NotNil(t, p)
- for _, w := range p.Workers() {
- w.State().Set(internal.StateErrored)
+ for i := range p.Workers() {
+ p.Workers()[i].State().Set(internal.StateErrored)
}
_, err = p.Exec(payload.Payload{Body: []byte("hello")})
assert.Error(t, err)
+ p.Destroy(ctx)
}
// identical to replace but controlled on worker side