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

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

src/s/a/sahara-HEAD/sahara/tests/integration/tests/swift.py   sahara(Download)
class SwiftTest(base.ITestCase):
    @base.skip_test(
        'SKIP_SWIFT_TEST',
        message='Test for check of Swift availability was skipped.')
    def check_swift_availability(self, cluster_info):

src/s/a/sahara-HEAD/sahara/tests/integration/tests/scaling.py   sahara(Download)
class ScalingTest(base.ITestCase):
    def _change_node_info_while_ng_adding(self, ngt_id, count, cluster_info):
        cluster_info['node_info']['node_count'] += count
        node_processes = self.sahara.node_group_templates.get(
            ngt_id).node_processes

src/s/a/sahara-HEAD/sahara/tests/integration/tests/map_reduce.py   sahara(Download)
class MapReduceTest(base.ITestCase):
    def _run_pi_job(self):
        self.execute_command('./script.sh run_pi_job')
 
    def _get_name_of_completed_pi_job(self):

src/s/a/sahara-HEAD/sahara/tests/integration/tests/edp.py   sahara(Download)
class EDPTest(base.ITestCase):
 
    def _create_data_source(self, name, data_type, url, description=''):
        return self.sahara.data_sources.create(
            name, description, data_type, url, self.common_config.OS_USERNAME,

src/s/a/sahara-HEAD/sahara/tests/integration/tests/cluster_configs.py   sahara(Download)
class ClusterConfigTest(base.ITestCase):
    @staticmethod
    def _get_node_configs(node_group, process):
        return node_group['node_configs'][CONFIG_MAP[process]['service']]
 

src/s/a/sahara-HEAD/sahara/tests/integration/tests/cinder.py   sahara(Download)
class CinderVolumeTest(base.ITestCase):
    def _get_node_list_with_volumes(self, cluster_info):
        data = self.sahara.clusters.get(cluster_info['cluster_id'])
        node_groups = data.node_groups
        node_list_with_volumes = []

src/s/a/sahara-2014.1/sahara/tests/integration/tests/vanilla_transient_cluster.py   sahara(Download)
class TransientClusterTest(base.ITestCase):
    @base.skip_test(
        'SKIP_TRANSIENT_CLUSTER_TEST',
        message='Test for transient cluster was skipped.')
    def transient_cluster_testing(self, plugin_config, floating_ip_pool,

src/s/a/sahara-2014.1/sahara/tests/integration/tests/swift.py   sahara(Download)
class SwiftTest(base.ITestCase):
    @base.skip_test(
        'SKIP_SWIFT_TEST',
        message='Test for check of Swift availability was skipped.')
    def check_swift_availability(self, cluster_info):

src/s/a/sahara-2014.1/sahara/tests/integration/tests/scaling.py   sahara(Download)
class ScalingTest(base.ITestCase):
    def _change_node_info_while_ng_adding(self, ngt_id, count, cluster_info):
        cluster_info['node_info']['node_count'] += count
        node_processes = self.sahara.node_group_templates.get(
            ngt_id).node_processes

src/s/a/sahara-2014.1/sahara/tests/integration/tests/map_reduce.py   sahara(Download)
class MapReduceTest(base.ITestCase):
    def _run_pi_job(self):
        self.execute_command('./script.sh run_pi_job')
 
    def _get_name_of_completed_pi_job(self):

  1 | 2  Next