小编The*_*oki的帖子

GAE Python Deferred.defer 设置“task_retry_limit”不起作用

我希望我的推迟任务在失败后才再次尝试。

阅读此相关问题后:Specifying retry limit fortasks queued using GAE deferred library很明显,我需要遵循已接受的答案,因此我将代码修改为如下所示:

from google.appengine.ext import deferred

deferred.defer(MyFunction, DATA, _retry_options={'task_retry_limit': 1})
Run Code Online (Sandbox Code Playgroud)

现在我得到这个错误:

File "/usr/local/google-cloud-sdk/platform/google_appengine/google/appengine/ext/deferred/deferred.py", line 269, in defer
    return task.add(queue, transactional=transactional)
File "/usr/local/google-cloud-sdk/platform/google_appengine/google/appengine/api/taskqueue/taskqueue.py", line 1143, in add
    return self.add_async(queue_name, transactional).get_result()
File "/usr/local/google-cloud-sdk/platform/google_appengine/google/appengine/api/taskqueue/taskqueue.py", line 1139, in add_async
    return Queue(queue_name).add_async(self, transactional, rpc)
File "/usr/local/google-cloud-sdk/platform/google_appengine/google/appengine/api/taskqueue/taskqueue.py", line 1889, in add_async
rpc)
File "/usr/local/google-cloud-sdk/platform/google_appengine/google/appengine/api/taskqueue/taskqueue.py", line 2008, in __AddTasks
    fill_request(task, request.add_add_request(), transactional)
File "/usr/local/google-cloud-sdk/platform/google_appengine/google/appengine/api/taskqueue/taskqueue.py", line 2093, in __FillAddPushTasksRequest
    task.retry_options, task_request.mutable_retry_parameters())
File "/usr/local/google-cloud-sdk/platform/google_appengine/google/appengine/api/taskqueue/taskqueue.py", line 2033, in __FillTaskQueueRetryParameters
    if …
Run Code Online (Sandbox Code Playgroud)

python google-app-engine

0
推荐指数
1
解决办法
390
查看次数

标签 统计

google-app-engine ×1

python ×1