luigi per-task retry policy

Question

luigi per-task retry-policyを設定する際に問題があります。次のように私はグローバルluigi.cfgファイルを設定した：

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回失敗しました）。

私には欠点があります。

Answer 1

この例でも動作しない場合。私はあなたのサーバーまたはクライアントコードが期限切れであると信じています。 luigiコマンドはインストールされたバージョンを実行し、パッケージのアップグレード後にセントラルサーバーを再起動する必要があることに注意してください。