| 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")
|
|
|