Index: impl/prod/taskqueue.go |
diff --git a/impl/prod/taskqueue.go b/impl/prod/taskqueue.go |
index 86ba154cb81384ac4a865fb14fd23b479bf6945e..5af3d546cfe8609a45f0de9c1c0bbba2ff5b3437 100644 |
--- a/impl/prod/taskqueue.go |
+++ b/impl/prod/taskqueue.go |
@@ -17,11 +17,8 @@ import ( |
// useTQ adds a gae.TaskQueue implementation to context, accessible |
// by gae.GetTQ(c) |
func useTQ(c context.Context) context.Context { |
- return tq.SetRawFactory(c, func(ci context.Context, wantTxn bool) tq.RawInterface { |
- if wantTxn { |
- return tqImpl{AEContext(ci)} |
- } |
- return tqImpl{AEContextNoTxn(ci)} |
+ return tq.SetRawFactory(c, func(ci context.Context) tq.RawInterface { |
+ return tqImpl{AEContext(ci)} |
}) |
} |
@@ -135,6 +132,6 @@ func (t tqImpl) Stats(queueNames []string, cb tq.RawStatsCB) error { |
return nil |
} |
-func (t tqImpl) Testable() tq.Testable { |
+func (t tqImpl) GetTestable() tq.Testable { |
return nil |
} |