def watch_appropriate_nodes
        remaining_paths.last( threshold + 1 ).reverse_each do |path|
          next if watched_paths.include? path
          watched_paths << path
          finish_node(path) unless zk.exists?(path, :watch => true)
        end
      end
def watch_appropriate_nodes
        remaining_paths.last( threshold + 1 ).reverse_each do |path|
          next if watched_paths.include? path
          watched_paths << path
          finish_node(path) unless zk.exists?(path, :watch => true)
        end
      end
ensures that threshold + 1 nodes are being watched