resque 작업에 대한 시간 초과 설정 방법

Question

특정 시간 내에 처리되지 않으면 시간 초과 작업을 재개 할 수있는 기능을 구현해야합니다.

그래서 작업이 생성되었지만 대기열이 너무 길거나 작업을 수행 할 수있는 직원이 충분하지 않아 한 시간 내에 처리 할 수 ​​없다고 가정합니다.

나는 그런 일에 삭제 될 일을하지 않았다 ... 그 일을하는 가장 좋은 방법은 무엇인가? 어쩌면 내가 감독하거나 제 3 자 보석 인 구성 매개 변수가 있을까요?

감사

Answer 1

기본적으로 Resque에서이 작업을 수행 할 수있는 방법이 있는지 모르겠어요,하지만 자신을 할 어렵지 않을 것입니다. ,

def perform(id, queued_at) 
    return false unless Time.parse(queued_at) >= 1.hour.ago 

    ... 
end 

그리고 작업을 대기열하기 위해 수행합니다 : 당신의 일에

은 같은 것을 할 Resque.enqueue (MyJobClass, object.id, DateTime.now). 첫 번째 줄은 작업을 자동으로 덤프하고 한 시간 이상 대기 한 경우 수행되지 않도록합니다.