

def all_clusters_active(self, dct):
    for (cluster, client) in dct.items():
        cluster_status = cluster.status.lower()
        if (cluster_status == 'error'):
            raise exceptions.SaharaClusterFailure(name=cluster.name, action='start', reason=cluster.status_description)
        elif (cluster_status != 'active'):
            return False
    return True

dataset/ETHPy150Open openstack/rally/rally/plugins/openstack/context/sahara/sahara_cluster.py SaharaCluster.all_clusters_active/original