lib/right_chimp/Chimp.rb in right_chimp-2.1.2 vs lib/right_chimp/Chimp.rb in right_chimp-2.1.3
- old
+ new
@@ -1128,10 +1128,11 @@
#
# load up remote chimpd jobs into the local queue
# this makes all the standard queue control methods available to us
#
+ sleeping_counter = 0
while true
local_queue.reset!
begin
all = ChimpDaemonClient.retrieve_group_info(@chimpd_host, @chimpd_port, @group, :all)
@@ -1143,11 +1144,15 @@
ChimpQueue.instance.create_group(@group)
ChimpQueue[@group].set_jobs(all)
break if ChimpQueue[@group].done?
+ if sleeping_counter % 240 == 0
+ $stdout.print "\nWaiting for group #{@group}" unless sleeping_counter == 0
+ end
$stdout.print "."
$stdout.flush
+ sleeping_counter += 5
sleep 5
end
#
# If verify_results returns true, then ask chimpd to requeue all failed jobs.