Oban.scale_queue

You're seeing just the function scale_queue, go back to Oban module for more information.
Link to this function

scale_queue(name \\ __MODULE__, opts)

View Source (since 0.2.0)

Specs

scale_queue(name(), opts :: [queue_option()]) :: :ok

Scale the concurrency for a queue.

Options

  • :queue - a string or atom specifying the queue to scale, required
  • :limit — the new concurrency limit
  • :local_only — whether the queue will be scaled only on the local node, default: false

Example

Scale a queue up, triggering immediate execution of queued jobs:

Oban.scale_queue(queue: :default, limit: 50)
:ok

Scale the queue back down, allowing executing jobs to finish:

Oban.scale_queue(queue: :default, limit: 5)
:ok

Scale the queue only on the local node:

Oban.scale_queue(queue: :default, limit: 10, local_only: true)
:ok