Packages

gust

0.1.7
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 flows run.ex
Raw

lib/gust/flows/run.ex 

defmodule Gust.Flows.Run do

  @moduledoc false



  use Ecto.Schema

  import Ecto.Changeset



  schema "runs" do

    belongs_to :dag, Gust.Flows.Dag



    field :status, Ecto.Enum,

      values: [:created, :running, :succeeded, :failed, :retrying, :enqueued],

      default: :created



    has_many :tasks, Gust.Flows.Task



    timestamps(type: :utc_datetime)

  end



  @doc false

  def changeset(run, attrs) do

    run

    |> cast(attrs, [:dag_id, :status])

    |> validate_required([:dag_id, :status])

  end



  @doc false

  def test_changeset(run, attrs) do

    run

    |> cast(attrs, [:dag_id, :status, :inserted_at])

    |> validate_required([:dag_id, :status])

  end

end