From 82c360a2524262c4ddcb2c35035d1067553e44d1 Mon Sep 17 00:00:00 2001 From: Wojciech Tyczynski Date: Wed, 5 Oct 2016 13:15:08 +0200 Subject: [PATCH] Make gets for previous value in watch serializable --- pkg/storage/etcd3/watcher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/storage/etcd3/watcher.go b/pkg/storage/etcd3/watcher.go index 5f78bbb4f26..1a6bbbf2464 100644 --- a/pkg/storage/etcd3/watcher.go +++ b/pkg/storage/etcd3/watcher.go @@ -332,7 +332,7 @@ func prepareObjs(ctx context.Context, e *event, client *clientv3.Client, codec r } } if e.isDeleted || !e.isCreated { - getResp, err := client.Get(ctx, e.key, clientv3.WithRev(e.rev-1)) + getResp, err := client.Get(ctx, e.key, clientv3.WithRev(e.rev-1), clientv3.WithSerializable()) if err != nil { return nil, nil, err }