Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(10)  |  Call(10)  |  Derive(0)  |  Import(0)

src/s/a/sahara-2014.1/sahara/service/engine.py   sahara(Download)
        ips_assigned = set()
        while len(ips_assigned) != len(instances):
            if not g.check_cluster_exists(instances[0].node_group.cluster):
                return
            for instance in instances:
            context.sleep(5)
 
            if not g.check_cluster_exists(instance.node_group.cluster):
                return
 

src/s/a/sahara-HEAD/sahara/service/engine.py   sahara(Download)
        ips_assigned = set()
        while len(ips_assigned) != len(instances):
            if not g.check_cluster_exists(instances[0].node_group.cluster):
                return
            for instance in instances:
            context.sleep(5)
 
            if not g.check_cluster_exists(instance.node_group.cluster):
                return
 

src/s/a/sahara-2014.1/sahara/service/direct_engine.py   sahara(Download)
        active_ids = set()
        while len(active_ids) != len(instances):
            if not g.check_cluster_exists(instances[0].node_group.cluster):
                return
            for instance in instances:

src/s/a/sahara-HEAD/sahara/service/direct_engine.py   sahara(Download)
        active_ids = set()
        while len(active_ids) != len(instances):
            if not g.check_cluster_exists(instances[0].node_group.cluster):
                return
            for instance in instances:

src/s/a/sahara-2014.1/sahara/plugins/vanilla/v2_3_0/run_scripts.py   sahara(Download)
            context.sleep(1)
 
            if not g.check_cluster_exists(cluster):
                LOG.info(
                    'Stop waiting datanodes on cluster %s since it has '

src/s/a/sahara-2014.1/sahara/plugins/vanilla/v1_2_1/versionhandler.py   sahara(Download)
                context.sleep(1)
 
                if not g.check_cluster_exists(cluster):
                    LOG.info(
                        'Stop waiting datanodes on cluster %s since it has '

src/s/a/sahara-HEAD/sahara/plugins/vanilla/v2_3_0/run_scripts.py   sahara(Download)
            context.sleep(1)
 
            if not g.check_cluster_exists(cluster):
                LOG.info(
                    'Stop waiting datanodes on cluster %s since it has '

src/s/a/sahara-HEAD/sahara/plugins/vanilla/v1_2_1/versionhandler.py   sahara(Download)
                context.sleep(1)
 
                if not g.check_cluster_exists(cluster):
                    LOG.info(
                        'Stop waiting datanodes on cluster %s since it has '