Packages

oban_web

2.11.2
2.12.6 2.12.5 2.12.4 2.12.3 2.12.2 2.12.1 2.12.0 2.11.8 2.11.7 2.11.6 2.11.5 2.11.4 2.11.3 2.11.2 2.11.1 2.11.0

Dashboard for the Oban job orchestration framework

HexDocs

Current section

Files

Jump to
Readme
16 Versions
7 Dependencies
Dependants
2 Advisories
Files
Activity
oban_web lib oban web helpers queue_helper.ex
Raw

lib/oban/web/helpers/queue_helper.ex 

defmodule Oban.Web.Helpers.QueueHelper do

  @moduledoc false



  alias Oban.Web.{Queue, Timing}



  def executing_count(checks) do

    checks

    |> List.wrap()

    |> Enum.map(&length(&1["running"]))

    |> Enum.sum()

  end



  def started_at(%{checks: _} = queue) do

    queue

    |> Queue.started_at()

    |> Timing.to_words()

  end



  def started_at(checks) do

    %Queue{checks: checks}

    |> Queue.started_at()

    |> Timing.to_words()

  end

end