Packages

step_flow

1.6.0
1.9.0-rc2 1.9.0-rc1 1.9.0-rc0 1.8.2 1.8.1 1.8.1-rc8 1.8.1-rc7 1.8.1-rc6 1.8.1-rc5 1.8.1-rc4 1.8.1-rc3 1.8.1-rc2 1.8.1-rc1 1.8.1-rc0 1.8.0 1.8.0-rc3 1.8.0-rc2 1.8.0-rc1 1.8.0-rc0 1.7.3 1.7.3-rc4 1.7.3-rc3 1.7.3-rc2 1.7.3-rc1 1.7.3-rc0 1.7.2 1.7.2-rc4 1.7.2-rc3 1.7.2-rc2 1.7.2-rc1 1.7.2-rc0 1.7.1 1.7.0 1.7.0-rc1 1.7.0-rc0 1.6.1 1.6.1-rc1 1.6.1-rc0 1.6.0 1.6.0-rc9 1.6.0-rc8 1.6.0-rc7 1.6.0-rc6 1.6.0-rc5 1.6.0-rc4 1.6.0-rc3 1.6.0-rc20 1.6.0-rc2 1.6.0-rc19 1.6.0-rc18 1.6.0-rc17 1.6.0-rc16 1.6.0-rc15 1.6.0-rc14 1.6.0-rc13 1.6.0-rc12 1.6.0-rc11 1.6.0-rc10 1.6.0-rc1 1.5.0 1.5.0-rc1 1.4.2-rc2 1.4.2-rc1 1.4.1 1.4.1-rc1 1.4.0 1.4.0-rc4 1.4.0-rc3 1.4.0-rc2 1.4.0-rc1 1.3.1 1.3.0 1.3.0-rc 1.2.0 1.1.0 1.0.0 1.0.0-rc9 1.0.0-rc8 1.0.0-rc7 1.0.0-rc6 1.0.0-rc5 1.0.0-rc1 0.2.13 0.2.12 0.2.11 0.2.10 0.2.9 0.2.8 0.2.7 0.2.6 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.0.24 0.0.23 0.0.22 0.0.21 0.0.20 0.0.19 0.0.18 0.0.17 0.0.16 0.0.15 0.0.14 0.0.13 0.0.12 0.0.11 0.0.10 0.0.9 0.0.8 0.0.7 0.0.6 0.0.4 0.0.3 0.0.2 0.0.1

Step flow manager for Elixir applications

HexDocs

Current section

Files

Jump to
Readme
128 Versions
23 Dependencies
Dependants
Files
Activity
step_flow lib step_flow models jobs job.ex
Raw

lib/step_flow/models/jobs/job.ex 

defmodule StepFlow.Jobs.Job do

  use Ecto.Schema

  import Ecto.Changeset

  alias StepFlow.Jobs.Job

  alias StepFlow.Jobs.Status

  alias StepFlow.LiveWorkers.LiveWorker

  alias StepFlow.Progressions.Progression

  alias StepFlow.Updates.Update

  alias StepFlow.Workflows.Workflow



  @moduledoc false



  schema "step_flow_jobs" do

    field(:name, :string)

    field(:step_id, :integer)

    field(:parameters, {:array, :map}, default: [])

    field(:is_live, :boolean, default: false)

    field(:is_updatable, :boolean, default: false)

    field(:allow_failure, :boolean, default: false)

    belongs_to(:workflow, Workflow, foreign_key: :workflow_id)

    has_many(:status, Status, on_delete: :delete_all)

    has_many(:progressions, Progression, on_delete: :delete_all)

    has_many(:updates, Update, on_delete: :delete_all)

    has_one(:live_worker, LiveWorker, on_delete: :delete_all)

    field(:last_worker_instance_id, :string, default: "")



    timestamps()

  end



  @doc false

  def changeset(%Job{} = job, attrs) do

    job

    |> cast(attrs, [

      :name,

      :step_id,

      :parameters,

      :is_live,

      :is_updatable,

      :allow_failure,

      :last_worker_instance_id,

      :workflow_id

    ])

    |> foreign_key_constraint(:workflow_id)

    |> validate_required([:name, :step_id, :parameters, :workflow_id])

  end

end