Sha256: 3b0aed530607de9ffa050334650eadbcdeec2f21d546361984d26b256c0c7bb6
Contents?: true
Size: 392 Bytes
Versions: 16
Compression:
Stored size: 392 Bytes
Contents
module SSHKit
module Runner
class Group < Sequential
attr_writer :group_size
def execute
hosts.each_slice(group_size).collect do |group_hosts|
Parallel.new(group_hosts, &block).execute
sleep wait_interval
end.flatten
end
private
def group_size
@group_size || options[:limit] || 2
end
end
end
end
Version data entries
16 entries across 14 versions & 3 rubygems