Index: impl/prod/taskqueue.go |
diff --git a/impl/prod/taskqueue.go b/impl/prod/taskqueue.go |
index 08c3441ccfca6b4e6f8b0c46fabd75fc166e7b40..77cd201dd613820a2a7217b726c9117d505509af 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{AEContextNoTxn(ci)} |
}) |
} |