mirror of
https://github.com/ash-project/ash_oban.git
synced 2024-09-20 13:23:08 +12:00
23 lines
523 B
Elixir
23 lines
523 B
Elixir
defmodule AshOban.Test do
|
|
@moduledoc "Helpers for testing ash_oban triggers"
|
|
|
|
def schedule_and_run_triggers(resource) do
|
|
triggers =
|
|
AshOban.Info.oban_triggers(resource)
|
|
|
|
Enum.each(triggers, fn trigger ->
|
|
AshOban.schedule(resource, trigger)
|
|
end)
|
|
|
|
triggers
|
|
|> Enum.map(& &1.queue)
|
|
|> Enum.uniq()
|
|
|> Enum.reduce(%{}, fn queue, acc ->
|
|
[queue: queue]
|
|
|> Oban.drain_queue()
|
|
|> Map.merge(acc, fn _key, left, right ->
|
|
left + right
|
|
end)
|
|
end)
|
|
end
|
|
end
|