View Source Lightning.Runs.Queue (Lightning v2.12.2)

Allows adding, removing or claiming work to be executed by the Runtime.

Summary

Functions

claim(demand, base_query, worker_name \\ nil)

Functions

Link to this function

claim(demand, base_query, worker_name \\ nil)

View Source 
@spec claim(non_neg_integer(), Ecto.Query.t(), String.t() | nil) ::
  {:ok, [Lightning.Run.t()]} | {:error, Ecto.Changeset.t(Lightning.Run.t())}