Packages

step_flow

1.9.0-rc2
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
25 Dependencies
Dependants
Files
Activity
step_flow lib step_flow controllers worker_status.ex
Raw

lib/step_flow/controllers/worker_status.ex 

defmodule StepFlow.Controllers.WorkerStatus do

  @moduledoc false



  @doc false

  defp get_instance_id_from_system_info(worker_status) do

    StepFlow.Map.get_by_key_or_atom(worker_status, :system_info)

    |> StepFlow.Map.get_by_key_or_atom(:docker_container_id)

  end



  @doc false

  def process_worker_status_message(%{:job => job_status, :worker => worker_status}) do

    worker_status =

      worker_status

      |> Map.put_new(:instance_id, get_instance_id_from_system_info(worker_status))



    worker_status

    |> Map.put(:current_job, job_status)

  end



  @doc false

  def process_worker_status_message(%{"job" => job_status, "worker" => worker_status}) do

    worker_status =

      worker_status

      |> Map.put_new("instance_id", get_instance_id_from_system_info(worker_status))



    worker_status

    |> Map.put("current_job", job_status)

  end



  def process_worker_status_message(%StepFlow.Progressions.Progression{} = message) do

    %{

      activity: "Busy",

      instance_id: message.docker_container_id,

      direct_messaging_queue_name: "direct_messaging_" <> message.docker_container_id,

      current_job: %{

        execution_duration: 0,

        job_id: message.job_id,

        status: "processing"

      }

    }

  end



  @doc false

  def process_worker_status_message(%{:activity => _activity} = message), do: message

  def process_worker_status_message(message) when message == %{}, do: message

end