Sidekiq::Client uses the "default" queue by default
In various places we use Sidekiq::Client
, and Sidekiq::Client.push_bulk
in particular. This code however uses the queue default
unless you specify one yourself. For example, this:
Sidekiq::Client.push_bulk('class' => ExpireBuildInstanceArtifactsWorker, 'args' => build_ids)
Will end up pushing all jobs into the default
queue. Code such as this should be changed to:
Sidekiq::Client.push_bulk('class' => ExpireBuildInstanceArtifactsWorker, 'args' => build_ids, 'queue' => ExpireBuildInstanceArtifactsWorker.sidekiq_options['queue'])
This ensures jobs go into the queues they belong in. Not doing so can lead to jobs taking forever to process.