Sorry @thojanssens1 I was handling some other things last week.
:at
is consumed through a function in the orechestrator:
defp to_entry_point_map(entry_point) do
%{
queue: Keyword.fetch!(entry_point, :queue),
...
at: Keyword.get(entry_point, :at)
}
end
That function is called by the orchestrate function:
def orchestrate(opts \\ []) do
exq_pid = opts[:exq_pid] || ExqApi
{:ok, scheduled_jobs} = ExqApi.scheduled(exq_pid)
for entry_point <- entry_points() do
entry_point
|> to_entry_point_map()
|> start_missing_jobs!(scheduled_jobs)
end
end
start_missing_jobs!/2
starts jobs that are scheduled based on the arguments consumed from to_entry_point_map/1