Packages

step_flow

0.0.18
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
16 Dependencies
Dependants
Files
Activity
step_flow lib step_flow jobs status.ex
Raw

lib/step_flow/jobs/status.ex 

defmodule StepFlow.Jobs.Status do

  use Ecto.Schema

  import Ecto.Changeset

  import EctoEnum



  alias StepFlow.Jobs.Job

  alias StepFlow.Jobs.Status

  alias StepFlow.Repo



  @moduledoc false



  defenum(StateEnum, ["queued", "skipped", "processing", "retrying", "error", "completed"])



  def state_enum_label(value) do

    case value do

      value when value in [0, :queued] -> "queued"

      value when value in [1, :skipped] -> "skipped"

      value when value in [2, :processing] -> "processing"

      value when value in [3, :retrying] -> "retrying"

      value when value in [4, :error] -> "error"

      value when value in [5, :completed] -> "completed"

      _ -> "unknown"

    end

  end



  schema "step_flow_status" do

    field(:state, StepFlow.Jobs.Status.StateEnum)

    field(:description, :map, default: %{})

    belongs_to(:job, Job, foreign_key: :job_id)



    timestamps()

  end



  @doc false

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

    job

    |> cast(attrs, [:state, :job_id, :description])

    |> foreign_key_constraint(:job_id)

    |> validate_required([:state, :job_id])

  end



  def set_job_status(job_id, status, description \\ %{}) do

    %Status{}

    |> Status.changeset(%{job_id: job_id, state: status, description: description})

    |> Repo.insert()

  end



  @doc """

  Returns the last updated status of a list of status.

  """

  def get_last_status(status) when is_list(status) do

    status

    |> Enum.sort(fn state_1, state_2 ->

      state_1.updated_at < state_2.updated_at

    end)

    |> List.last()

  end



  def get_last_status(%Status{} = status), do: status

  def get_last_status(_status), do: nil

end