Current section
Files
Jump to
Current section
Files
lib/gust/dag/terminator.ex
defmodule Gust.DAG.Terminator do
@callback kill_task(task :: term(), status :: term()) :: any()
@callback cancel_timer(task :: term(), status :: term()) :: any()
# coveralls-ignore-start
def kill_task(task, status), do: impl().kill_task(task, status)
def cancel_timer(task, status), do: impl().cancel_timer(task, status)
def impl(), do: Application.get_env(:gust, :dag_terminator, Gust.DAG.Terminator.Process)
# coveralls-ignore-stop
end