ash-project/ash_oban
1
0
Fork 0
mirror of https://github.com/ash-project/ash_oban.git synced 2024-09-20 05:13:15 +12:00
Code Issues Projects Releases Packages Wiki Activity

chore: don't drain queues 4 times

Browse source
This commit is contained in:
Zach Daniel 2023-12-20 10:53:45 -05:00
parent 3cad6a4233
commit 2667527827
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/ash_oban.ex
View file

@ -685,7 +685,7 @@ defmodule AshOban do
defp drain_queues(queues, opts) do
if opts[:drain_queues?] do
Enum.reduce(queues ++ queues, %{}, fn queue, acc ->
Enum.reduce(queues, %{}, fn queue, acc ->
[queue: queue]
|> Keyword.merge(
Keyword.take(opts, [:queue, :with_limit, :with_recursion, :with_safety, :with_scheduled])