Oban Pro Relay Plugin Mini-Demo

relay_testing.exs

alias Oban.Pro.Plugins.Relay

Oban.Pro.Repo.start_link()

Oban.start_link(
  repo: Oban.Pro.Repo,
  queues: [alpha: 2],
  plugins: [Oban.Pro.Plugins.Relay]
)

defmodule Worker do
  use Oban.Worker, queue: :alpha

  @impl Worker
  def perform(%{args: %{"msg" => msg}}) do
    {:ok, "#{msg} from #{node()}"}
  end
end

~w(foo bar baz)
|> Enum.map(&Worker.new(%{msg: &1}))
|> Enum.map(&Relay.async/1)
|> Relay.await_many()