Lightning.Runs.Queue (Lightning v2.19.0-pre)

View Source

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

Summary

Functions

claim(demand, base_query, worker_name \\ nil, queues \\ ["manual", "*"])

Functions

claim(demand, base_query, worker_name \\ nil, queues \\ ["manual", "*"])

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