def check_started_workers
begin
100.times do |ii|
warn "Checking started workers, #{active_workers.size} out of #{@number_of_workers} after the #{(ii+1)}th try..."
break if active_workers.size >= @number_of_workers
sleep (@number_of_workers - active_workers.size)
end
rescue Exception => e
fatal "Something bad happened #{e.inspect} #{e.backtrace.join("\n")}"
end
@all_workers_started = true
printlog "FINISHED STARTING ALL #{active_workers.size} WORKERS"
if active_workers.size > @number_of_workers
warn "EXPECTED #{@number_of_workers}"
@number_of_workers = active_workers.size
end
end