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

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

src/s/a/sahara-2014.1/sahara/tests/integration/tests/map_reduce.py   sahara(Download)
    def _run_pi_job(self):
        self.execute_command('./script.sh run_pi_job')
 
    def _get_name_of_completed_pi_job(self):
        try:
            job_name = self.execute_command('./script.sh get_pi_job_name')
    def _run_wordcount_job(self):
        try:
            self.execute_command('./script.sh run_wordcount_job')
 
        except Exception as e:
                try:
                    self.execute_command(
                        './script.sh check_directory -job_name %s' % job_name)
                    have_logs = True
                except Exception:

src/s/a/sahara-HEAD/sahara/tests/integration/tests/map_reduce.py   sahara(Download)
    def _run_pi_job(self):
        self.execute_command('./script.sh run_pi_job')
 
    def _get_name_of_completed_pi_job(self):
        try:
            job_name = self.execute_command('./script.sh get_pi_job_name')
    def _run_wordcount_job(self):
        try:
            self.execute_command('./script.sh run_wordcount_job')
 
        except Exception as e:
                try:
                    self.execute_command(
                        './script.sh check_directory -job_name %s' % job_name)
                    have_logs = True
                except Exception:

src/s/a/sahara-2014.1/sahara/tests/integration/tests/swift.py   sahara(Download)
        swift.put_container(swift_container_name)
        try:
            self.execute_command('./script.sh')
 
        except Exception as e:

src/s/a/sahara-HEAD/sahara/tests/integration/tests/swift.py   sahara(Download)
        swift.put_container(swift_container_name)
        try:
            self.execute_command('./script.sh')
 
        except Exception as e:

src/s/a/sahara-2014.1/sahara/tests/integration/tests/cluster_configs.py   sahara(Download)
    def _compare_configs_on_cluster_node(self, config, value):
        config = config.replace(' ', '')
        try:
            self.execute_command('./script.sh %s -value %s' % (config, value))
 

src/s/a/sahara-2014.1/sahara/tests/integration/tests/cinder.py   sahara(Download)
            volume_count_on_node = int(
                self.execute_command(
                    'mount | grep %s | wc -l' % node_with_volumes[
                        'volume_mount_prefix']
                )[1])

src/s/a/sahara-HEAD/sahara/tests/integration/tests/cluster_configs.py   sahara(Download)
    def _compare_configs_on_cluster_node(self, config, value):
        config = config.replace(' ', '')
        try:
            self.execute_command('./script.sh %s -value %s' % (config, value))
 

src/s/a/sahara-HEAD/sahara/tests/integration/tests/cinder.py   sahara(Download)
            volume_count_on_node = int(
                self.execute_command(
                    'mount | grep %s | wc -l' % node_with_volumes[
                        'volume_mount_prefix']
                )[1])