diff options
| -rw-r--r-- | lib/storage.rb | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/lib/storage.rb b/lib/storage.rb index 29311ad..6e41ed7 100644 --- a/lib/storage.rb +++ b/lib/storage.rb @@ -89,17 +89,17 @@ module Ag::Storage }) # Give elasticsearch some time to process the new index - status = $es.indices.status(index: indexname) - pp status - pp status['indices'][indexname]['shards'] - status = status['indices'][indexname]['shards'].map do |k,v| - v[0]['routing']['state'] - end - pp status while $es.cluster.health['status'] != 'green' do - pp $es.indices.status(index: indexname) - sleep 0.01 + status = $es.indices.status(index: indexname) + pp status + pp status['indices'][indexname]['shards'] + status = status['indices'][indexname]['shards'].map do |k,v| + v[0]['routing']['state'] + end + pp status + sleep 0.01 end + pp $es.indices.status(index: indexname) end def get_content(message, filename) |