Packages

gust

0.1.5
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 loader dir.ex
Raw

lib/gust/dag/loader/dir.ex 

defmodule Gust.DAG.Loader.Dir do

  @moduledoc false

  alias Gust.Flows

  alias Gust.DAG.Parser



  @behaviour Gust.DAG.Loader



  def load(dags_folder) do

    dags = Flows.list_dags()



    found_dags =

      ex_files(dags_folder)

      |> Enum.map(&"#{Path.absname(dags_folder)}/#{&1}")

      |> Enum.filter(&Parser.maybe_using_dsl(&1))

      |> Enum.reject(&is_nil/1)

      |> Enum.map(&(&1 |> Path.basename() |> Path.rootname()))

      |> Enum.map(&get_or_create_dag(&1))



    removed_dags = (dags -- found_dags) |> Enum.map(&Flows.delete_dag!(&1))

    {found_dags, removed_dags}

  end



  def get_definitions() do

    Gust.DAG.Loader.Worker.get_definitions()

  end



  def reload_definition(dag_id) do

    Gust.DAG.Loader.Worker.reload_definition(dag_id)

  end



  defp ex_files(folder) do

    folder

    |> File.ls!()

    |> Enum.filter(&Parser.maybe_ex_file(&1))

  end



  defp get_or_create_dag(name) do

    case Flows.get_dag_by_name(name) do

      %Flows.Dag{} = dag ->

        dag



      nil ->

        {:ok, dag} = Flows.create_dag(%{name: name})

        dag

    end

  end

end