Packages

step_flow

1.6.0-rc3
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 progressions progression.ex
Raw

lib/step_flow/progressions/progression.ex 

defmodule StepFlow.Progressions.Progression do

  use Ecto.Schema

  import Ecto.Changeset

  alias StepFlow.Jobs.Job

  alias StepFlow.Progressions.Progression



  @moduledoc false



  schema "step_flow_progressions" do

    field(:datetime, :utc_datetime)

    field(:docker_container_id, :string)

    field(:progression, :integer)

    field(:system_info, :map)

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



    timestamps()

  end



  @doc false

  def changeset(%Progression{} = progression, attrs) do

    progression

    |> cast(attrs, [:datetime, :docker_container_id, :system_info, :job_id, :progression])

    |> foreign_key_constraint(:job_id)

    |> validate_required([:datetime, :docker_container_id, :job_id, :progression])

  end



  @doc """

  Returns the last updated progression of a list of progression.

  """

  def get_last_progression(progression) when is_list(progression) do

    progression

    |> Enum.sort(fn progression_1, progression_2 ->

      case NaiveDateTime.compare(progression_1.inserted_at, progression_2.inserted_at) do

        :lt -> true

        :gt -> false

        :eq -> progression_1.id < progression_2.id

      end

    end)

    |> List.last()

  end



  def get_last_progression(%Progression{} = progression), do: progression

  def get_last_progression(_progression), do: nil

end