Skip queue existence check for pause/resume all

Closes #1000

lib/oban.ex

@@ -1322,11 +1322,18 @@ defmodule Oban do
   end
 
   defp validate_queue_exists!(name, opts) do
-    queue = opts[:queue]
-    local_only = opts[:local_only]
+    queue = Keyword.fetch!(opts, :queue)
+    lonly = Keyword.get(opts, :local_only, false)
 
-    if local_only && is_nil(Registry.whereis(name, {:producer, to_string(queue)})) do
-      raise ArgumentError, "queue #{inspect(queue)} does not exist locally"
+    cond do
+      queue == :* ->
+        :ok
+
+      lonly and is_nil(Registry.whereis(name, {:producer, to_string(queue)})) ->
+        raise ArgumentError, "queue #{inspect(queue)} does not exist locally"
+
+      true ->
+        :ok
     end
   end
 end

test/oban_test.exs

@@ -351,6 +351,34 @@ defmodule ObanTest do
         assert %{paused: false} = Oban.check_queue(name, queue: :delta)
       end)
     end
+
+    test "pausing and resuming all local queues" do
+      opts = [queues: [alpha: 1, gamma: 1]]
+
+      name1 = start_supervised_oban!(opts)
+      name2 = start_supervised_oban!(opts)
+
+      assert :ok = Oban.pause_all_queues(name1, local_only: true)
+
+      with_backoff(fn ->
+        assert %{paused: true} = Oban.check_queue(name1, queue: :alpha)
+        assert %{paused: true} = Oban.check_queue(name1, queue: :gamma)
+
+        assert %{paused: false} = Oban.check_queue(name2, queue: :alpha)
+        assert %{paused: false} = Oban.check_queue(name2, queue: :gamma)
+      end)
+
+      assert :ok = Oban.pause_all_queues(name2, local_only: true)
+      assert :ok = Oban.resume_all_queues(name1, local_only: true)
+
+      with_backoff(fn ->
+        assert %{paused: false} = Oban.check_queue(name1, queue: :alpha)
+        assert %{paused: false} = Oban.check_queue(name1, queue: :gamma)
+
+        assert %{paused: true} = Oban.check_queue(name2, queue: :alpha)
+        assert %{paused: true} = Oban.check_queue(name2, queue: :gamma)
+      end)
+    end
   end
 
   describe "scale_queue/2" do