Restore zero arity version of pause_all_queues/0

Both pause and resume variants lost their default argument in a refactor that shifted around guard clauses.
sorentwo · Apr 17, 2024 · d173011 · d173011
1 parent b66ee14
commit d173011
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/lib/oban.ex b/lib/oban.ex
@@ -921,6 +921,7 @@ defmodule Oban do
   end
 
   @doc false
+  def pause_all_queues(name \\ Oban)
   def pause_all_queues(opts) when is_list(opts), do: pause_all_queues(__MODULE__, opts)
   def pause_all_queues(name), do: pause_all_queues(name, [])
 
@@ -995,6 +996,7 @@ defmodule Oban do
   end
 
   @doc false
+  def resume_all_queues(name \\ Oban)
   def resume_all_queues(opts) when is_list(opts), do: resume_all_queues(__MODULE__, opts)
   def resume_all_queues(name), do: resume_all_queues(name, [])
 

diff --git a/test/support/exercise.ex b/test/support/exercise.ex
@@ -44,5 +44,17 @@ defmodule Oban.Test.Exercise do
     %Multi{} = Oban.insert_all(Oban, Multi.new(), :job, [changeset], timeout: 500)
   end
 
+  def check_pause_resume_all do
+    Oban.pause_all_queues()
+    Oban.pause_all_queues(Oban)
+    Oban.pause_all_queues(Oban, local_only: true)
+    Oban.pause_all_queues(local_only: true)
+
+    Oban.resume_all_queues()
+    Oban.resume_all_queues(Oban)
+    Oban.resume_all_queues(Oban, local_only: true)
+    Oban.resume_all_queues(local_only: true)
+  end
+
   defp changeset, do: Job.new(%{}, worker: "FakeWorker")
 end