| Index: impl/prod/taskqueue.go
|
| diff --git a/impl/prod/taskqueue.go b/impl/prod/taskqueue.go
|
| index 1c9763bd2e1efeb96ab42819090ab2ef109362c7..014b852634c13743e5102560ff7148d6f5f99060 100644
|
| --- a/impl/prod/taskqueue.go
|
| +++ b/impl/prod/taskqueue.go
|
| @@ -8,8 +8,8 @@ import (
|
| "fmt"
|
| "reflect"
|
|
|
| - "github.com/luci/gae"
|
| tq "github.com/luci/gae/service/taskqueue"
|
| + "github.com/luci/luci-go/common/errors"
|
| "golang.org/x/net/context"
|
| "google.golang.org/appengine/taskqueue"
|
| )
|
| @@ -81,7 +81,7 @@ func tqF2R(n *tq.Task) *taskqueue.Task {
|
| // *taskqueue.Task to a slice of *tq.Task
|
| func tqMR2FErr(os []*taskqueue.Task, err error) ([]*tq.Task, error) {
|
| if err != nil {
|
| - return nil, gae.FixError(err)
|
| + return nil, errors.Fix(err)
|
| }
|
| ret := make([]*tq.Task, len(os))
|
| for i, t := range os {
|
| @@ -114,7 +114,7 @@ func (t tqImpl) AddMulti(tasks []*tq.Task, queueName string) ([]*tq.Task, error)
|
| return tqMR2FErr(taskqueue.AddMulti(t.Context, tqMF2R(tasks), queueName))
|
| }
|
| func (t tqImpl) DeleteMulti(tasks []*tq.Task, queueName string) error {
|
| - return gae.FixError(taskqueue.DeleteMulti(t.Context, tqMF2R(tasks), queueName))
|
| + return errors.Fix(taskqueue.DeleteMulti(t.Context, tqMF2R(tasks), queueName))
|
| }
|
|
|
| //////// TQLeaser
|
|
|