module Sidekiq::Portal::CoreExtensions::SidekiqWorker
@api private @since 0.1.0
Public Instance Methods
run_scheduled()
click to toggle source
@return [void]
@api public @since 0.1.0
# 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