Packages

orchid

0.3.0
0.6.2 0.6.1 0.6.0 0.5.8 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.1 0.4.0 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0

A lightweight and extensible workflow orchestration engine, written in Elixir.

HexDocs

Current section

Files

Jump to
Readme
20 Versions
1 Dependency
Dependants
Files
Activity
orchid lib orchid scheduler context.ex
Raw

lib/orchid/scheduler/context.ex 

defmodule Orchid.Scheduler.Context do

  alias Orchid.{Param, Step, Recipe}



  @type param_map :: %{optional(atom()) => Param.t()}

  @type t :: %__MODULE__{


          recipe: Recipe.t(),


          pending_steps: [{Step.t(), non_neg_integer()}],


          available_keys: MapSet.t(Step.io_key()),


          params: param_map(),


          running_steps: MapSet.t(Step.t()),


          history: [{non_neg_integer(), param_map() | [Param.t()] | Param.t()}],


          assings: %{any() => any()}


        }

  defstruct [

    # Recipe 本体


    # 用于 Executor 使用（为了保持一致性，不允许做修改）


    :recipe,

    ## 原始 Orchid


    # 还未执行的步骤列表


    :pending_steps,

    # 当前已有的数据 keys


    :available_keys,

    # 实际数据本体


    :params,

    # 正在运行中的 steps


    :running_steps,

    # 执行历史


    :history,

    ## 可能的其他上下文


    :assings

  ]

end