work_recovery.ex

defmodule OpenAgents.WorkRecovery do
  @moduledoc false

  use GenServer, restart: :temporary

  def start_link(options) do
    GenServer.start_link(__MODULE__, options, name: __MODULE__)
  end

  @impl true
  def init(options) do
    recovery = Keyword.get(options, :recovery, &OpenAgents.Work.recover_interrupted_jobs/0)
    :ok = recovery.()
    {:ok, %{}}
  end
end

Code

lib/openagents/work_recovery.ex