Current section
Files
Jump to
Current section
Files
lib/gust/dag/run_restarter.ex
defmodule Gust.DAG.RunRestarter do
@moduledoc false
@callback restart([term()]) :: :ok
@callback restart_enqueued(term()) :: :ok
def restart(dags), do: impl().restart(dags)
def restart_enqueued(dag), do: impl().restart_enqueued(dag)
defp impl, do: Application.get_env(:gust, :dag_run_restarter)
# TODO: Could unify with startert
end