Index: impl/memory/taskqueue_test.go |
diff --git a/impl/memory/taskqueue_test.go b/impl/memory/taskqueue_test.go |
index 50cb1b02e674eec67cd0b4012dbaf2a901feb6ed..eb2de337aea324b5c6b4e29c2ef91d1c2d022cdf 100644 |
--- a/impl/memory/taskqueue_test.go |
+++ b/impl/memory/taskqueue_test.go |
@@ -370,6 +370,16 @@ func TestTaskQueue(t *testing.T) { |
}, nil), ShouldBeNil) |
}) |
+ Convey("can get the non-transactional taskqueue context though", func() { |
+ So(dsS.Get(c).RunInTransaction(func(c context.Context) error { |
+ So(tqS.GetNoTxn(c).Delete(t, ""), ShouldBeNil) |
+ So(tqS.GetNoTxn(c).Purge(""), ShouldBeNil) |
+ _, err := tqS.GetNoTxn(c).Stats("") |
+ So(err, ShouldBeNil) |
+ return nil |
+ }, nil), ShouldBeNil) |
+ }) |
+ |
Convey("adding a new task only happens if we don't errout", func() { |
So(dsS.Get(c).RunInTransaction(func(c context.Context) error { |
t3 := tq.NewTask("/sandwitch/victory") |