luigi每任务重试策略

我在配置luigi每任务重试策略时遇到问题。我如下配置的全局luigi.cfg文件：luigi每任务重试策略

class SomeTask(luigi.Task): 

    retry_count = 3

将重写路易吉RETRY_COUNT足够了：

[scheduler] 
retry-delay: 1 
retry_count: 5 

[worker] 
keep_alive: true 
wait_interval: 3

此外，重要的是写一个任务如下路易吉配置手册中规定在luigi.cfg中指定。但是，此设置完全不会影响运行。我设法创建了一个每次仅用于测试都失败的任务，并且记录返回此任务失败5次（而不是3次）。

我觉得有一些基本的东西我错过了。

来源

2016-09-20 maxim orlov

在这里没有真正的解决方案，但重试示例是否适合您？ https://github.com/spotify/luigi/blob/bfb62337011ec24ceda7eece5e8526aa57d1cf06/examples/per_task_retry_policy.py – MattMcKnight

@MattMcKnight好吧，其实不... –

我已经确认了同样的问题，我正在发送拉请求。 https://github.com/spotify/luigi/pull/2012 –

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

来源

2016-10-05 08:46:48 Tarrasch

luigi每任务重试策略

回答

相关问题