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