Packages

gust

0.1.13
0.1.37 0.1.36 0.1.35 0.1.34 0.1.33 0.1.32 0.1.31 0.1.30 0.1.29 0.1.28 0.1.27 0.1.26 0.1.25 0.1.24 0.1.23 0.1.22 0.1.21 0.1.20 0.1.19 0.1.18 0.1.17 0.1.16 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.2 0.1.1 0.1.0

A DAG-Based Workflow Orchestration Engine for Elixir

HexDocs

Current section

Files

Jump to
Readme
37 Versions
9 Dependencies
Dependants
Files
Activity
gust lib gust dag run_restarter.ex
Raw

lib/gust/dag/run_restarter.ex 

# TODO: Rename module and funcitons

defmodule Gust.DAG.RunRestarter do

  @moduledoc false



  @callback start_dag(term()) :: term()

  @callback restart_run(term()) :: :ok

  @callback restart_task(term(), term()) :: :ok

  @callback restart([term()]) :: :ok

  @callback restart_enqueued(term()) :: :ok



  def start_dag(dag_id), do: impl().start_dag(dag_id)

  def restart_run(run), do: impl().restart_run(run)

  def restart_task(graph, task), do: impl().restart_task(graph, task)

  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)

end