integration: sync lapi server after puts in TestLeaseTimeToLive
Linearized read to ensure the keys have committed.
@@ -482,7 +482,8 @@ func TestLeaseTimeToLive(t *testing.T) {
clus := integration.NewClusterV3(t, &integration.ClusterConfig{Size: 3})
defer clus.Terminate(t)
- lapi := clus.RandClient()
+ c := clus.RandClient()
+ lapi := c
resp, err := lapi.Grant(context.Background(), 10)
if err != nil {
@@ -497,6 +498,11 @@ func TestLeaseTimeToLive(t *testing.T) {
}
}
+ // linearized read to ensure Puts propagated to server backing lapi
+ if _, err := c.Get(context.TODO(), "abc"); err != nil {
+ t.Fatal(err)
+ }
+
lresp, lerr := lapi.TimeToLive(context.Background(), resp.ID, clientv3.WithAttachedKeys())
if lerr != nil {
t.Fatal(lerr)
