luigi per-task 재시도 정책

Question

luigi per task 재시도 정책을 구성하는 데 문제가 있습니다. 다음과 같이 I 글로벌 luigi.cfg 파일을 구성한 :

class SomeTask(luigi.Task): 

    retry_count = 3 

는 루이지에서 Retry_count를 오버라이드 (override)에 충분할 것 또한

[scheduler] 
retry-delay: 1 
retry_count: 5 

[worker] 
keep_alive: true 
wait_interval: 3 

, 그것은 작업을 작성하는 것은 다음과 같이 루이지 구성 설명서에 명시 luigi.cfg에 지정되어 있습니다. 그러나이 설정은 실행에 전혀 영향을주지 않습니다. 필자는 테스트 할 때마다 실패한 작업을 만들었으며 로깅은이 작업이 5 회 실패했음을 반환합니다 (3 회가 아님).

나는 근본적으로 뭔가 빠져 있다고 생각합니다.

Answer 1

심지어 예제가 작동하지 않는 경우. 귀하의 서버 또는 클라이언트 코드가 오래되었다고 생각합니다. luigi 명령은 설치된 버전을 실행하고 패키지를 업그레이드 한 후 중앙 서버를 다시 시작해야합니다.