Lightning.Runs.Queue (Lightning v2.13.5)

View Source

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

Summary

Functions

claim(demand, base_query, worker_name \\ nil)

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