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.