fix: another syntax issue with drain_queue/2

ash-project · Aug 4, 2023 · ee4827c · ee4827c
1 parent 6bd0058
commit ee4827c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/test.ex b/lib/test.ex
@@ -13,8 +13,8 @@ defmodule AshOban.Test do
     |> Enum.map(& &1.queue)
     |> Enum.uniq()
     |> Enum.reduce(%{}, fn queue, acc ->
-      queue
-      |> Oban.drain_queue(queue: queue)
+      [queue: queue]
+      |> Oban.drain_queue()
       |> Map.merge(acc, fn _key, left, right ->
         left + right
       end)