Packages

gust

0.1.9
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 dsl.ex
Raw

lib/gust/dsl.ex 

defmodule Gust.DSL do

  defmacro __using__(dag_options) do

    quote do

      import unquote(__MODULE__), only: [task: 2, task: 3]



      Module.register_attribute(__MODULE__, :dag_tasks, accumulate: true)



      def __dag_options__, do: unquote(dag_options)



      @before_compile unquote(__MODULE__)

    end

  end



  defmacro __before_compile__(_env) do

    quote do

      def __dag_tasks__, do: @dag_tasks

    end

  end



  defmacro task(name, opts_and_ctx, do: block) do

    {ctx_pattern, opts} = Keyword.pop(opts_and_ctx, :ctx)

    ctx_pattern = ctx_pattern || quote do: %{run_id: run_id}



    quote do

      @dag_tasks {unquote(name), unquote(opts)}



      def unquote(name)(ctx) do

        unquote(ctx_pattern) = ctx

        unquote(block)

      end

    end

  end



  defmacro task(name, do: block) do

    quote do

      @dag_tasks {unquote(name), []}



      def unquote(name)(ctx) do

        unquote(block)

      end

    end

  end

end