Chromium Code Reviews| Index: impl/prod/taskqueue.go |
| diff --git a/impl/prod/taskqueue.go b/impl/prod/taskqueue.go |
| index 08c3441ccfca6b4e6f8b0c46fabd75fc166e7b40..b224b05268c6d4977868fba4cec6994515f31de9 100644 |
| --- a/impl/prod/taskqueue.go |
| +++ b/impl/prod/taskqueue.go |
| @@ -17,8 +17,11 @@ 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) tq.RawInterface { |
| - return tqImpl{AEContext(ci)} |
| + return tq.SetRawFactory(c, func(ci context.Context, wantTxn bool) tq.RawInterface { |
| + if wantTxn { |
| + return tqImpl{AEContext(ci)} |
| + } |
| + return tqImpl{AEContextNoTX(ci)} |
|
Vadim Sh.
2015/12/04 03:22:04
why this is so much simpler than the others (or, w
|
| }) |
| } |