Index: go/src/infra/gae/libs/meta/eg_test.go |
diff --git a/go/src/infra/gae/libs/meta/eg_test.go b/go/src/infra/gae/libs/meta/eg_test.go |
index 472bfcdcca509408962a4e5c79f7f0404a9a11d1..1a97c7a19563b4aaf7dd8a109220cdb92cb76f2f 100644 |
--- a/go/src/infra/gae/libs/meta/eg_test.go |
+++ b/go/src/infra/gae/libs/meta/eg_test.go |
@@ -5,11 +5,13 @@ |
package meta |
import ( |
+ "errors" |
"testing" |
"golang.org/x/net/context" |
"infra/gae/libs/gae" |
+ "infra/gae/libs/gae/filters/featureBreaker" |
"infra/gae/libs/gae/memory" |
. "github.com/smartystreets/goconvey/convey" |
@@ -20,6 +22,7 @@ func TestGetEntityGroupVersion(t *testing.T) { |
Convey("GetEntityGroupVersion", t, func() { |
c := memory.Use(context.Background()) |
+ c, fb := featureBreaker.FilterRDS(c, errors.New("INTERNAL_ERROR")) |
rds := gae.GetRDS(c) |
aKey, err := rds.Put(rds.NewKey("A", "", 0, nil), gae.DSPropertyMap{ |
@@ -41,8 +44,7 @@ func TestGetEntityGroupVersion(t *testing.T) { |
So(err, ShouldBeNil) |
So(v, ShouldEqual, 0) |
- tDs := rds.(gae.Testable) |
- tDs.BreakFeatures(nil, "Get") |
+ fb.BreakFeatures(nil, "Get") |
v, err = GetEntityGroupVersion(c, aKey) |
So(err.Error(), ShouldContainSubstring, "INTERNAL_ERROR") |