python - luigi 每任务重试策略

Question

我在配置 luigi per-task retry-policy 时遇到问题。我已将全局 luigi.cfg 文件配置如下：

[scheduler]
retry-delay: 1
retry_count: 5

[worker]
keep_alive: true
wait_interval: 3

此外，它在 luigi 配置手册中指出编写任务如下：

class SomeTask(luigi.Task):

   retry_count = 3

足以覆盖 luigi.cfg 中指定的 luigi retry_count。但是，此设置根本不会影响运行。我设法创建了一个每次都失败的任务，只是为了测试，并且记录返回这个任务失败了 5 次（而不是 3 次）。

我认为我缺少一些基本的东西。

Answer 1

如果连这个例子都不起作用。我相信您的服务器或客户端代码已过时。请注意，该luigi命令将运行您安装的版本，并且在软件包升级后需要重新启动中央服务器。