| 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
|
| }
|
|
|