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/edp/workflow_creator/workflow_factory.py   sahara(Download)
    def get_workflow_xml(self, cluster, execution, input_data, output_data):
        job_dict = {'configs': self.get_configs(input_data, output_data)}
        self.update_job_dict(job_dict, execution.job_configs)
        creator = mapreduce_workflow.MapReduceWorkFlowCreator()
        creator.build_workflow_xml(configuration=job_dict['configs'],

src/s/a/sahara-HEAD/sahara/service/edp/workflow_creator/workflow_factory.py   sahara(Download)
    def get_workflow_xml(self, cluster, execution, input_data, output_data):
        job_dict = {'configs': self.get_configs(input_data, output_data)}
        self.update_job_dict(job_dict, execution.job_configs)
        creator = mapreduce_workflow.MapReduceWorkFlowCreator()
        creator.build_workflow_xml(configuration=job_dict['configs'],

src/s/a/sahara-HEAD/sahara/tests/unit/service/edp/workflow_creator/test_create_workflow.py   sahara(Download)
      </streaming>"""
 
        mr_workflow = mrw.MapReduceWorkFlowCreator()
        mr_workflow.build_workflow_xml(self.prepare, self.job_xml,
                                       self.configuration, self.files,
                                       self.archives, self.streaming)
        res = mr_workflow.get_built_workflow_xml()
        self.assertIn(mr_action, res)
 
        mr_workflow = mrw.MapReduceWorkFlowCreator()
        self.assertNotIn(mr_action, res)
 
        mr_workflow = mrw.MapReduceWorkFlowCreator()
        with self.assertRaises(ex.NotFoundException):
            mr_workflow.build_workflow_xml(self.prepare, self.job_xml,
                                           self.configuration, self.files,
                                           self.archives, {'bogus': 'element'})
 
    def test_create_mapreduce_workflow(self):
        mr_workflow = mrw.MapReduceWorkFlowCreator()

src/s/a/sahara-2014.1/sahara/tests/unit/service/edp/workflow_creator/test_create_workflow.py   sahara(Download)
      </streaming>"""
 
        mr_workflow = mrw.MapReduceWorkFlowCreator()
        mr_workflow.build_workflow_xml(self.prepare, self.job_xml,
                                       self.configuration, self.files,
                                       self.archives, self.streaming)
        res = mr_workflow.get_built_workflow_xml()
        self.assertIn(mr_action, res)
 
        mr_workflow = mrw.MapReduceWorkFlowCreator()
        self.assertNotIn(mr_action, res)
 
        mr_workflow = mrw.MapReduceWorkFlowCreator()
        with self.assertRaises(ex.NotFoundException):
            mr_workflow.build_workflow_xml(self.prepare, self.job_xml,
                                           self.configuration, self.files,
                                           self.archives, {'bogus': 'element'})
 
    def test_create_mapreduce_workflow(self):
        mr_workflow = mrw.MapReduceWorkFlowCreator()