CODEWITHSUNDEEP
rubysidekiq
dagda1
dagda1

Reputation: 28910

Get sidekiq to execute a job immediately

At the moment, I have a sidekiq job like this:

class SyncUser
  include Sidekiq::Worker

  def perform(user_id)
    #do stuff
  end
end

I am placing a job on the queue like this:

SyncUser.perform_async user.id

This all works of course but there is a bit of a lag between calling perform_async and the job actually getting executed.

Is there anything else I can do to tell sidekiq to execute the job immediately?

Upvotes: 88

Views: 84051

Answers (3)

nikolayp
nikolayp

Reputation: 17949

use .perform_inline

SyncUser.perform_inline(user.id)

or even in your production console:

require 'sidekiq/testing'
Sidekiq::Testing.inline!

SyncUser.perform_inline(user.id)

Upvotes: 13

Daniel Morris
Daniel Morris

Reputation: 6892

For those who are using Sidekiq via the Active Job framework, you can do

SyncUser.perform_now(user.id)

Upvotes: -3

Winfield
Winfield

Reputation: 19145

There are two questions here.

If you want to execute a job immediately, in the current context you can use:

SyncUser.new.perform(user.id)

If you want to decrease the delay between asynchronous work being scheduled and when it's executed in the sidekiq worker, you can decrease the poll_interval setting:

Sidekiq.configure_server do |config|
  config.poll_interval = 2
end

The poll_interval is the delay within worker backends of how frequently workers check for jobs on the queue. The average time between a job being scheduled and executed with a free worker will be poll_interval / 2.

Upvotes: 163

Related Questions