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