diff --git a/tests/integration/clientv3/concurrency/session_test.go b/tests/integration/clientv3/concurrency/session_test.go index 8aad8df25ed9..5b1156bd4b64 100644 --- a/tests/integration/clientv3/concurrency/session_test.go +++ b/tests/integration/clientv3/concurrency/session_test.go @@ -171,9 +171,12 @@ func TestTimeoutDoesntAffectSubsequentConnections(t *testing.T) { clus.Members[0].Terminate(t) donec := make(chan struct{}) + errorc := make(chan error) go func() { defer close(donec) - _, _ = cli.Put(s.Ctx(), "sample_key", "sample_value", clientv3.WithLease(s.Lease())) + if _, err := cli.Put(s.Ctx(), "sample_key", "sample_value", clientv3.WithLease(s.Lease())); err != nil { + errorc <- err + } }() select { @@ -188,6 +191,8 @@ func TestTimeoutDoesntAffectSubsequentConnections(t *testing.T) { clus.Members[0].Restart(t) select { case <-donec: + case err := <-errorc: + t.Errorf("Put failed: %v", err) case <-time.After(1 * time.Second): t.Fatal("Put function hung even after restarting cluster") }