| Index: impl/memory/taskqueue_data.go
|
| diff --git a/impl/memory/taskqueue_data.go b/impl/memory/taskqueue_data.go
|
| index c8420a86d79108513b034438fcfcf1c110d77e42..906da1c8fe7a9a6ef687c9a384c01436106ffecd 100644
|
| --- a/impl/memory/taskqueue_data.go
|
| +++ b/impl/memory/taskqueue_data.go
|
| @@ -13,7 +13,7 @@ import (
|
|
|
| "golang.org/x/net/context"
|
|
|
| - rds "github.com/luci/gae/service/rawdatastore"
|
| + ds "github.com/luci/gae/service/datastore"
|
| tq "github.com/luci/gae/service/taskqueue"
|
| "github.com/luci/luci-go/common/clock"
|
| )
|
| @@ -56,7 +56,7 @@ func (t *taskQueueData) applyTxn(c context.Context, obj memContextObj) {
|
| }
|
| txn.anony = nil
|
| }
|
| -func (t *taskQueueData) mkTxn(*rds.TransactionOptions) memContextObj {
|
| +func (t *taskQueueData) mkTxn(*ds.TransactionOptions) memContextObj {
|
| return &txnTaskQueueData{
|
| parent: t,
|
| anony: tq.AnonymousQueueData{},
|
| @@ -190,9 +190,9 @@ var (
|
| _ = tq.Testable((*txnTaskQueueData)(nil))
|
| )
|
|
|
| -func (t *txnTaskQueueData) canApplyTxn(obj memContextObj) bool { return false }
|
| -func (t *txnTaskQueueData) applyTxn(context.Context, memContextObj) { panic("impossible") }
|
| -func (t *txnTaskQueueData) mkTxn(*rds.TransactionOptions) memContextObj { panic("impossible") }
|
| +func (t *txnTaskQueueData) canApplyTxn(obj memContextObj) bool { return false }
|
| +func (t *txnTaskQueueData) applyTxn(context.Context, memContextObj) { panic("impossible") }
|
| +func (t *txnTaskQueueData) mkTxn(*ds.TransactionOptions) memContextObj { panic("impossible") }
|
|
|
| func (t *txnTaskQueueData) endTxn() {
|
| if atomic.LoadInt32(&t.closed) == 1 {
|
|
|