Packages

gust

0.1.32
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 runtime adapters elixir.ex
Raw

lib/gust/dag/runtime/adapters/elixir.ex 

defmodule Gust.DAG.Runtime.Adapters.Elixir do

  @moduledoc false



  @behaviour Gust.DAG.Runtime.Adapter



  alias Gust.DAG.Definition



  @impl true

  def setup(%Definition{} = dag_def, runtime_id) do

    runtime_mod = compile(dag_def, runtime_id)

    %{dag_def | mod: runtime_mod}

  end



  @impl true

  def teardown(%Definition{mod: mod}, _runtime_id) do

    purge(mod)

    :ok

  end



  @impl true

  def on_finished_callback(%Definition{mod: mod}, fn_name, run, status) do

    apply(mod, fn_name, [status, run])

    :ok

  end



  @impl true

  def kill(task_pid) do

    true = Process.exit(task_pid, :kill)

    :ok

  end



  defp compile(%Definition{file_path: file_path} = dag_def, runtime_id) do

    {:ok, ast} = Code.string_to_quoted(File.read!(file_path))



    runtime_mod = Module.concat(["Gust", "Runner", "#{dag_def.mod}_#{runtime_id}"])

    dag_ast = patch_module(ast, runtime_mod)



    {dag_module, _} = Code.compile_quoted(dag_ast, file_path) |> List.first()

    dag_module

  end



  defp purge(mod) do

    :code.purge(mod)

    :code.delete(mod)

  end



  defp patch_module(ast, runtime_mod) do

    Macro.postwalk(ast, fn

      {:defmodule, meta, [_module_ast_node, block]} ->

        {:defmodule, meta, [Module.concat([runtime_mod]), block]}



      node ->

        node

    end)

  end

end