class SSHKit::Runner::Group

Attributes

group_size[W]

Public Instance Methods

execute() click to toggle source
# File lib/sshkit/runners/group.rb, line 7
def execute
  hosts.each_slice(group_size).collect do |group_hosts|
    Parallel.new(group_hosts, &block).execute
    sleep wait_interval
  end.flatten
end

Private Instance Methods

group_size() click to toggle source
# File lib/sshkit/runners/group.rb, line 14
def group_size
  @group_size || options[:limit] || 2
end