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

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

src/s/a/sahara-2014.1/sahara/service/edp/api.py   sahara(Download)
def get_job_config_hints(job_type):
    return w_f.get_possible_job_config(job_type)
 
 
def execute_job(job_id, data):

src/s/a/sahara-HEAD/sahara/service/edp/api.py   sahara(Download)
def get_job_config_hints(job_type):
    return w_f.get_possible_job_config(job_type)
 
 
def execute_job(job_id, data):

src/s/a/sahara-2014.1/sahara/tests/unit/service/edp/test_job_possible_configs.py   sahara(Download)
    def test_possible_configs(self):
        res = w_f.get_possible_job_config("MapReduce")
        sample_config_property = {
            'name': 'mapred.map.tasks',
            'value': '2',
        self.assertIn(sample_config_property, res['job_config']["configs"])
 
        res = w_f.get_possible_job_config("Hive")
        sample_config_property = {
            "description": "The serde used by FetchTask to serialize the "
        }
        self.assertIn(sample_config_property, res["job_config"]['configs'])
        res = w_f.get_possible_job_config("impossible_config")
        self.assertIsNone(res)
 

src/s/a/sahara-HEAD/sahara/tests/unit/service/edp/test_job_possible_configs.py   sahara(Download)
    def test_possible_configs(self):
        res = w_f.get_possible_job_config(edp.JOB_TYPE_MAPREDUCE)
        sample_config_property = {
            'name': 'mapred.map.tasks',
            'value': '2',
        self.assertIn(sample_config_property, res['job_config']["configs"])
 
        res = w_f.get_possible_job_config(edp.JOB_TYPE_HIVE)
        sample_config_property = {
            "description": "The serde used by FetchTask to serialize the "
        }
        self.assertIn(sample_config_property, res["job_config"]['configs'])
        res = w_f.get_possible_job_config("impossible_config")
        self.assertIsNone(res)