У меня есть простое приложение Google App Engine, которое включает в себя/update страница, которая обновляет плейлист YouTube. Это выглядит так:

class UpdatePage(webapp2.RequestHandler):

    @decorator.oauth_required
    def get(self):
        update_result = self.update_playlist()
        ...

routes = [('/update', UpdatePage),
          (decorator.callback_path, decorator.callback_handler())]
app = webapp2.WSGIApplication(routes, debug=True)

Работает как положено иupdate_playlist() Метод выполняет свою работу, но оказывается, что при некоторых обстоятельствах он может работать довольно долго, что приводит кDeadlineExceededError, Поэтому, прочитав о доступных опциях, я понял,Очередь задач API - это путь, которым нужно (верно?), И яя пытаюсь использовать его, следуяИспользование Push-очередей в Python руководство. →

 Короче я разделилUpdatePage в +:UpdatePageHandlerUpdatePageWorker

class UpdateHandlerPage(webapp2.RequestHandler):

    @decorator.oauth_required
    def get(self):
        taskqueue.add(url='/updateworker')

class UpdateWorkerPage(webapp2.RequestHandler):

    def post(self):
        update_result = self.update_playlist()
        ...

routes = [('/update', UpdateHandlerPage),
          ('/updateworker', UpdateWorkerPage),
          (decorator.callback_path, decorator.callback_handler())]
app = webapp2.WSGIApplication(routes, debug=True)

К сожалению, после раскола кажется, что мой декоратор OAuth2 больше не выполняет свою работу:

INFO     2013-05-30 17:08:53,971 discovery.py:709] URL being requested: https://www.googleapis.com/youtube/v3/playlists?alt=json&part=snippet%2Cstatus
WARNING  2013-05-30 17:08:53,975 urlfetch_stub.py:480] Stripped prohibited headers from URLFetch request: ['content-length']
INFO     2013-05-30 17:08:54,351 client.py:493] Refreshing due to a 401
INFO     2013-05-30 17:08:54,361 appengine.py:276] make: Got type 
INFO     2013-05-30 17:08:54,363 appengine.py:289] validate: Got type 
INFO     2013-05-30 17:08:54,364 client.py:680] Refreshing access_token
INFO     2013-05-30 17:08:54,746 client.py:699] Failed to retrieve access token: {
  "error" : "invalid_grant"
}
INFO     2013-05-30 17:08:54,757 appengine.py:276] make: Got type 
INFO     2013-05-30 17:08:54,759 appengine.py:289] validate: Got type 
INFO     2013-05-30 17:08:54,761 appengine.py:289] validate: Got type 
INFO     2013-05-30 17:08:54,762 appengine.py:265] get: Got type 

И если вместо украшенияUpdateHandlerPage:get Я украшаюUpdateWorkerPage:postВместо этого я получаю бесконечный цикл ошибок:

INFO     2013-05-30 17:24:31,307 discovery.py:190] URL being requested: https://www.googleapis.com/discovery/v1/apis/youtube/v3/rest?userIp=127.0.0.1
INFO     2013-05-30 17:24:34,960 dev_appserver.py:3105] "GET /update HTTP/1.1" 200 -
INFO     2013-05-30 17:24:35,060 dev_appserver.py:3105] "POST /updateworker HTTP/1.1" 302 -
WARNING  2013-05-30 17:24:35,065 taskqueue_stub.py:1980] Task task1 failed to execute. This task will retry in 0.100 seconds
INFO     2013-05-30 17:24:35,240 dev_appserver.py:3105] "POST /updateworker HTTP/1.1" 302 -
WARNING  2013-05-30 17:24:35,245 taskqueue_stub.py:1980] Task task1 failed to execute. This task will retry in 0.200 seconds
...

Что я могу сделать? Спасибо за вашу помощь!