Sorry, I’m not able to reproduce the issue locally, or in a staging environment. Here are the commands:
iex(app@10.0.153.225)9> Oban.pause_queue(queue: :default)
:ok
iex(app@10.0.153.225)10> Oban.check_queue(queue: :default)
%{
name: "Oban",
node: "worker-i-07744c871b2ea59ba",
running: [],
queue: "default",
started_at: ~U[2024-10-23 18:32:56.023906Z],
updated_at: ~U[2024-10-24 19:07:34.908989Z],
uuid: "0192baa7-3fd7-78f7-9a6f-e70af8d41282",
paused: true,
global_limit: nil,
rate_limit: nil,
local_limit: 10
}
iex(app@10.0.153.225)11> Oban.Pro.Plugins.DynamicQueues.all() |> Enum.find(& &1.name == "default") |> Map.get(:opts)
%Oban.Pro.Queue.Opts{
ack_async: nil,
local_limit: 10,
paused: true,
refresh_interval: nil,
xact_delay: nil,
xact_retry: nil,
global_limit: nil,
rate_limit: nil
}
iex(app@10.0.153.225)12> Oban.resume_queue(queue: "default")
:ok
iex(app@10.0.153.225)13> Oban.Pro.Plugins.DynamicQueues.all() |> Enum.find(& &1.name == "default") |> Map.get(:opts)
%Oban.Pro.Queue.Opts{
ack_async: nil,
local_limit: 10,
paused: false,
refresh_interval: nil,
xact_delay: nil,
xact_retry: nil,
global_limit: nil,
rate_limit: nil
}
If you’re able to create a small reproduction I’m happy to continue investigating.
