def wait_for_status_green(self):
        logger.info("\nWait for %s cluster..." % Cluster.EXPECTED_CLUSTER_STATUS)
        stop_watch = self.clock.stop_watch()
        stop_watch.start()
        reached_cluster_status, relocating_shards = self._do_wait(Cluster.EXPECTED_CLUSTER_STATUS)
        stop_watch.stop()
        logger.info("Cluster reached status [%s] within [%.1f] sec." % (reached_cluster_status, stop_watch.total_time()))
        logger.info("Cluster health: %s" % str(self.client.cluster.health()))
        logger.info("SHARDS:\n%s" % self.client.cat.shards(v=True))
Long running message queue processor
dataset/ETHPy150Open elastic/rally/esrally/cluster.py/Cluster.wait_for_status_green--crossover with--dataset/ETHPy150Open garethr/Asteroid/asteroid/bin/asteroid_listen.py/run