Added logging for job reset task

This commit is contained in:
Kieran Eglin 2024-03-24 09:28:05 -07:00
parent aba15ed886
commit 610b00566b
No known key found for this signature in database
GPG key ID: 193984967FCF432D

View file

@ -43,7 +43,12 @@ defmodule Pinchflat.Boot.PreJobStartupTasks do
# in the "executing" state. This is a problem because the job runner will not
# pick them up again
defp reset_executing_jobs do
Repo.update_all(from(j in Oban.Job, where: j.state == "executing"), set: [state: "retryable"])
{count, _} =
Oban.Job
|> where(state: "executing")
|> Repo.update_all(set: [state: "retryable"])
Logger.info("Reset #{count} executing jobs")
end
defp apply_default_settings do