Delayed::Job再起動時にジョブがロックされたままにさせない

Delayed::Jobを気軽に再起動させたいために挙動確認した時のメモです.

実行環境

また、Delayed::Jobを起動する際に共通するオプションとして-n 2を指定する前提で書きます.

ソースコードは、graceful_delayedにまとめてあります.

再起動時にジョブがロックされたままにさせない

Delayed::Jobをbin/delayed_job経由で操作すると、daemonsというGemでWorkerプロセスが起動します.
このdaemonsは停止命令（stop）が実行されると、そのプロセスで処理が終了するまで待ち、プロセスを終了させます.
終了待機時間のデフォルト値は20秒となっており、20秒経っても処理が終了しない場合は処理を強制終了させます.

さてDelayed::Jobで20秒以上かかるジョブ実行中に、強制終了するとどうなるでしょうか？

実行中のジョブがロックされたまま、データベースに残り続けてしまいます.
こうなってしまうとQueueに残り続けてしまうゴミデータとなりますし、最悪の場合処理が失敗しているかもしれません.
では、ジョブがロックされたままにならないようにするにはどうしたら良いでしょうか？
私が考えた方法は2つあります.

  • raise_signal_exceptionsに:termもしくはtrueを指定する
  • daemonsの終了待機時間をDelayed::Worker.max_run_timeに数秒足した値を指定する（例: --daemon-options=-w,{seconds})

どちらが良いということもないはずなので、戦略的にどちらが良いのかを決めるのが良いでしょう.