Packages

gust

0.1.34
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
8 Dependencies
Dependants
Files
Activity
gust lib gust dag task_runner_supervisor dynamic_supervisor.ex
Raw

lib/gust/dag/task_runner_supervisor/dynamic_supervisor.ex 

defmodule Gust.DAG.TaskRunnerSupervisor.DynamicSupervisor do

  @moduledoc false

  alias Gust.DAG.Adapter



  @behaviour Gust.DAG.TaskRunnerSupervisor

  use DynamicSupervisor



  def start_link(init_arg) do

    DynamicSupervisor.start_link(__MODULE__, init_arg, name: __MODULE__)

  end



  @impl true

  def init(_init_arg) do

    DynamicSupervisor.init(strategy: :one_for_one)

  end



  @impl true

  def start_child(task, dag_def, stage_pid, opts) do

    spec =

      {worker(dag_def.adapter), %{task: task, dag_def: dag_def, stage_pid: stage_pid, opts: opts}}



    DynamicSupervisor.start_child(__MODULE__, spec)

  end



  def worker(adapter) do

    Adapter.impl!(adapter, :task_worker)

  end

end