Index: go/src/infra/gae/libs/meta/eg.go |
diff --git a/go/src/infra/gae/libs/meta/eg.go b/go/src/infra/gae/libs/meta/eg.go |
index 8522d5051d6dc7f5e98c26c8d945cb605a1780f0..c7038e5fbf5490ce87517aaaec264d4fe8e99c0b 100644 |
--- a/go/src/infra/gae/libs/meta/eg.go |
+++ b/go/src/infra/gae/libs/meta/eg.go |
@@ -10,6 +10,7 @@ import ( |
"github.com/luci/luci-go/common/errors" |
"infra/gae/libs/gae" |
+ "infra/gae/libs/gae/helper" |
) |
var mark = errors.MakeMarkFn("eg") |
@@ -28,15 +29,15 @@ func GetEntityGroupVersion(c context.Context, root gae.DSKey) (int64, error) { |
for root.Parent() != nil { |
root = root.Parent() |
} |
- egm := &EntityGroupMeta{} |
rds := gae.GetRDS(c) |
- err := rds.Get(rds.NewKey("__entity_group__", "", 1, root), egm) |
- if err != gae.ErrDSNoSuchEntity { |
- err = mark(err) |
- } else { |
+ egm := &EntityGroupMeta{} |
+ ret := int64(0) |
+ err := rds.Get(rds.NewKey("__entity_group__", "", 1, root), helper.GetPLS(egm)) |
+ ret = egm.Version |
+ if err == gae.ErrDSNoSuchEntity { |
// this is OK for callers. The version of the entity group is effectively 0 |
// in this case. |
err = nil |
} |
- return egm.Version, err |
+ return ret, err |
} |