From 3008fe16a860269c87c08be99eaea9fe1d49d4f4 Mon Sep 17 00:00:00 2001 From: Parker Selbert Date: Fri, 2 Apr 2021 10:54:21 -0500 Subject: [PATCH] Always use the BasicEngine when draining queues --- lib/oban/queue/drainer.ex | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/lib/oban/queue/drainer.ex b/lib/oban/queue/drainer.ex index 9a99b625..104cb824 100644 --- a/lib/oban/queue/drainer.ex +++ b/lib/oban/queue/drainer.ex @@ -9,6 +9,8 @@ defmodule Oban.Queue.Drainer do @infinite 100_000_000 def drain(%Config{} = conf, [_ | _] = opts) do + conf = %{conf | engine: BasicEngine} + args = opts |> Keyword.put_new(:with_recursion, false) @@ -30,8 +32,8 @@ defmodule Oban.Queue.Drainer do end defp fetch_available(conf, queue) do - {:ok, meta} = BasicEngine.init(conf, queue: queue, limit: @infinite) - {:ok, {_meta, jobs}} = BasicEngine.fetch_jobs(conf, meta, %{}) + {:ok, meta} = conf.engine.init(conf, queue: queue, limit: @infinite) + {:ok, {_meta, jobs}} = conf.engine.fetch_jobs(conf, meta, %{}) jobs end