Sha256: 071ef5c0dd9b4c562ed221fda3ebf8f9c12da2e74259242d4065711480e1e2e3

Contents?: true

Size: 344 Bytes

Versions: 2

Compression:

Stored size: 344 Bytes

Contents

# frozen_string_literal: true

# @api private
# @since 0.1.0
class Sidekiq::Portal::JobRunner
  require_relative 'job_runner/builder'

  # @param job [Sidekiq::Portal::Job]
  #
  # @api private
  # @since 0.1.0
  def run(job)
    return unless job.timeline.time_has_come?

    job.timeline.actualize_time!
    job.klass.perform_later
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
sidekiq_portal-0.1.1 lib/portal/job_runner.rb
sidekiq_portal-0.1.0 lib/portal/job_runner.rb