Module: Sidekiq::Portal::CoreExtensions::SidekiqWorker Private

Defined in:
lib/portal/core_extensions/sidekiq_worker.rb

Overview

This module is part of a private API. You should avoid using this module if possible, as it may be removed or be changed in the future.

Since:

  • 0.1.0

Instance Method Summary collapse

Instance Method Details

#run_scheduled ⇒ void

This method returns an undefined value.

Since:

  • 0.1.0



10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/portal/core_extensions/sidekiq_worker.rb', line 10

def run_scheduled
  timezone = Sidekiq::Portal.config[:default_timezone]
  timezoner = ActiveSupport::TimeZone[timezone]
  current_time = timezoner.at(Time.current)

  jobs.each do |job|
    next if job.key?('at') && timezoner.at(job['at']) > current_time

    Sidekiq::Queues.delete_for(job['jid'], job['queue'], job['class'])
    Sidekiq::Testing.constantize(job['class']).process_job(job)
  end
end