module Sidekiq::Group
Constants
- VERSION
Attributes
debug[RW]
Public Instance Methods
on_complete(_options = {})
click to toggle source
# File lib/sidekiq/group.rb, line 30 def on_complete(_options = {}) sidekiq_logger.warn 'on_complete function is not defined' end
sidekiq_group(options = {}) { |group| ... }
click to toggle source
# File lib/sidekiq/group.rb, line 14 def sidekiq_group(options = {}) raise NoBlockGivenError unless block_given? group = Sidekiq::Group::Collection.new group.callback_class = self.class.name group.callback_options = options Thread.current[:group_collection] = group yield(group) group.spawned_jobs! Thread.current[:group_collection] = nil end
sidekiq_logger()
click to toggle source
# File lib/sidekiq/group.rb, line 34 def sidekiq_logger Sidekiq::Logging.logger end