Add support for Pull Queues to prod implementation.

impl/memory/taskqueue.go

Index: impl/memory/taskqueue.go
diff --git a/impl/memory/taskqueue.go b/impl/memory/taskqueue.go
index 99b029a2feba65b9905bfe5fcfc2b36e73da39d6..35fc762122b11185647430e1a7fef2ef9b6785ca 100644
--- a/impl/memory/taskqueue.go
+++ b/impl/memory/taskqueue.go
@@ -105,6 +105,18 @@ func (t *taskqueueImpl) DeleteMulti(tasks []*tq.Task, queueName string, cb tq.Ra
 	return nil
 }
 
+func (t *taskqueueImpl) Lease(maxTasks int, queueName string, leaseTime int) ([]*tq.Task, error) {
+	panic("not implemented yet")
+}
+
+func (t *taskqueueImpl) LeaseByTag(maxTasks int, queueName string, leaseTime int, tag string) ([]*tq.Task, error) {
+	panic("not implemented yet")
+}
+
+func (t *taskqueueImpl) ModifyLease(task *tq.Task, queueName string, leaseTime int) error {
+	panic("not implemented yet")
+}
+
 func (t *taskqueueImpl) Purge(queueName string) error {
 	t.Lock()
 	defer t.Unlock()
@@ -208,6 +220,18 @@ func (t *taskqueueTxnImpl) DeleteMulti([]*tq.Task, string, tq.RawCB) error {
 	return errors.New("taskqueue: cannot DeleteMulti from a transaction")
 }
 
+func (t *taskqueueTxnImpl) Lease(maxTasks int, queueName string, leaseTime int) ([]*tq.Task, error) {
+	return nil, errors.New("taskqueue: cannot Lease from a transaction")
+}
+
+func (t *taskqueueTxnImpl) LeaseByTag(maxTasks int, queueName string, leaseTime int, tag string) ([]*tq.Task, error) {
+	return nil, errors.New("taskqueue: cannot LeaseByTag from a transaction")
+}
+
+func (t *taskqueueTxnImpl) ModifyLease(task *tq.Task, queueName string, leaseTime int) error {
+	return errors.New("taskqueue: cannot ModifyLease from a transaction")
+}
+
 func (t *taskqueueTxnImpl) Purge(string) error {
 	return errors.New("taskqueue: cannot Purge from a transaction")
 }