Index: filter/txnBuf/txnbuf_test.go |
diff --git a/filter/txnBuf/txnbuf_test.go b/filter/txnBuf/txnbuf_test.go |
index 6c0845e9d2ec6d1ba32ed4a1ec8425c4fcfc259c..3aabcf88484ea0cd0736919a7e7c3a374c88b330 100644 |
--- a/filter/txnBuf/txnbuf_test.go |
+++ b/filter/txnBuf/txnbuf_test.go |
@@ -247,11 +247,7 @@ func TestTransactionBuffers(t *testing.T) { |
So(under.PutMulti.Total(), ShouldEqual, 2) |
So(under.DeleteMulti.Total(), ShouldEqual, 2) |
- // 'over' Put operations are amplified because the inner transaction |
- // commits go through the 'over' filter on the outer transaction. So it's |
- // # Puts + # inner txns, times 2 because we are simulating a failed |
- // transaction. |
- So(over.PutMulti.Total(), ShouldEqual, 10) |
+ So(over.PutMulti.Total(), ShouldEqual, 8) |
So(7, fooShouldHave(ds)) |
So(3, fooShouldHave(ds), 10, 20, 30, 40) |
@@ -838,7 +834,7 @@ func TestQuerySupport(t *testing.T) { |
vals = []*Foo{} |
So(ds.GetAll(q, &vals), ShouldBeNil) |
- So(vals, ShouldResemble, []*Foo{foo1, projectData[0], foo7}) |
+ So(vals, ShouldResembleV, []*Foo{foo1, projectData[0], foo7}) |
return nil |
}, nil), ShouldBeNil) |
@@ -857,6 +853,7 @@ func TestQuerySupport(t *testing.T) { |
q := datastore.NewQuery("Foo").Ancestor(root) |
return ds.Run(q, func(pm datastore.PropertyMap, _ datastore.CursorCB) bool { |
So(ds.RunInTransaction(func(c context.Context) error { |
+ ds := datastore.Get(c) |
pm["Value"] = append(pm["Value"], datastore.MkProperty("wat")) |
return ds.Put(pm) |
}, nil), ShouldBeNil) |