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

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

src/s/a/sahara-2014.1/sahara/tests/unit/service/edp/test_job_manager.py   sahara(Download)
        job, _ = _create_all_stack('Pig')
        res = job_manager.create_workflow_dir(mock.Mock(), job, 'hadoop')
        self.assertIn('/user/hadoop/special_name/', res)
 
        remote.reset_mock()
        self.assertIn("""
      <param>INPUT=swift://ex.sahara/i</param>
      <param>OUTPUT=swift://ex.sahara/o</param>""", res)
 
        self.assertIn("""
          <value>admin</value>
        </property>
      </configuration>""", res)
 
        self.assertIn("<script>script.pig</script>", res)
          <value>admin</value>
        </property>
      </configuration>""", res)
 
        input_data = _create_data_source('hdfs://user/hadoop/in')

src/s/a/sahara-HEAD/sahara/tests/unit/service/edp/test_job_manager.py   sahara(Download)
        job, _ = _create_all_stack(edp.JOB_TYPE_PIG)
        res = job_manager.create_workflow_dir(mock.Mock(), job, 'hadoop')
        self.assertIn('/user/hadoop/special_name/', res)
 
        remote.reset_mock()
        self.assertIn("""
      <param>INPUT=swift://ex.sahara/i</param>
      <param>OUTPUT=swift://ex.sahara/o</param>""", res)
 
        self.assertIn("""
          <value>admin</value>
        </property>
      </configuration>""", res)
 
        self.assertIn("<script>script.pig</script>", res)
          <value>admin</value>
        </property>
      </configuration>""", res)
 
        input_data = _create_data_source('hdfs://user/hadoop/in')

src/s/a/sahara-2014.1/sahara/tests/unit/plugins/intel/test_plugin_3_0_2.py   sahara(Download)
    def test_get_configs(self):
        plugin = p.IDHProvider()
        configs = plugin.get_configs('3.0.2')
 
        self.assertIn(c_helper.IDH_REPO_URL, configs)
        self.assertIn(c_helper.IDH_TARBALL_URL, configs)
        self.assertIn(c_helper.OS_REPO_URL, configs)

src/s/a/sahara-2014.1/sahara/tests/unit/plugins/intel/test_plugin_2_5_1.py   sahara(Download)
    def test_get_configs(self):
        plugin = p.IDHProvider()
        configs = plugin.get_configs('2.5.1')
 
        self.assertIn(c_helper.IDH_REPO_URL, configs)
        self.assertIn(c_helper.IDH_TARBALL_URL, configs)
        self.assertIn(c_helper.OS_REPO_URL, configs)