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

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

src/s/a/sahara-2014.1/sahara/plugins/vanilla/v2_3_0/validation.py   sahara(Download)
    if rm_count == 0:
        if nm_count > 0:
            raise ex.RequiredServiceMissingException('resourcemanager',
                                                     required_by='nodemanager')
 
    if oo_count == 1:
        if dn_count < 1:
            raise ex.RequiredServiceMissingException('datanode',
                                                     required_by='oozie')
 
        if nm_count < 1:
            raise ex.RequiredServiceMissingException('nodemanager',
 
        if hs_count != 1:
            raise ex.RequiredServiceMissingException('historyserver',
                                                     required_by='oozie')
 

src/s/a/sahara-HEAD/sahara/plugins/vanilla/v2_3_0/validation.py   sahara(Download)
    if rm_count == 0:
        if nm_count > 0:
            raise ex.RequiredServiceMissingException('resourcemanager',
                                                     required_by='nodemanager')
 
    if oo_count == 1:
        if dn_count < 1:
            raise ex.RequiredServiceMissingException('datanode',
                                                     required_by='oozie')
 
        if nm_count < 1:
            raise ex.RequiredServiceMissingException('nodemanager',
 
        if hs_count != 1:
            raise ex.RequiredServiceMissingException('historyserver',
                                                     required_by='oozie')
 

src/s/a/sahara-2014.1/sahara/plugins/vanilla/v1_2_1/versionhandler.py   sahara(Download)
            if tt_count > 0:
                raise ex.RequiredServiceMissingException(
                    "jobtracker", required_by="tasktracker")
 
            if oozie_count > 0:
                raise ex.RequiredServiceMissingException(
                    "jobtracker", required_by="oozie")
            if hive_count > 0:
                raise ex.RequiredServiceMissingException(
                    "jobtracker", required_by="hive")
 
        if hive_count not in [0, 1]:

src/s/a/sahara-HEAD/sahara/plugins/vanilla/v1_2_1/versionhandler.py   sahara(Download)
            if tt_count > 0:
                raise ex.RequiredServiceMissingException(
                    "jobtracker", required_by="tasktracker")
 
            if oozie_count > 0:
                raise ex.RequiredServiceMissingException(
                    "jobtracker", required_by="oozie")
            if hive_count > 0:
                raise ex.RequiredServiceMissingException(
                    "jobtracker", required_by="hive")
 
        if hive_count not in [0, 1]:

src/s/a/sahara-2014.1/sahara/plugins/intel/v3_0_2/versionhandler.py   sahara(Download)
        if rm_count == 0 and tt_count > 0:
            raise ex.RequiredServiceMissingException(
                'resourcemanager', required_by='nodemanager')
 
        mng_count = sum([ng.count for ng

src/s/a/sahara-2014.1/sahara/plugins/intel/v2_5_1/versionhandler.py   sahara(Download)
        if jt_count == 0 and tt_count > 0:
            raise ex.RequiredServiceMissingException(
                'jobtracker', required_by='tasktracker')
 
        mng_count = sum([ng.count for ng

src/s/a/sahara-2014.1/sahara/plugins/hdp/clusterspec.py   sahara(Download)
                service.validate(self, cluster)
            elif service.is_mandatory():
                raise ex.RequiredServiceMissingException(service.name)
 
    def get_deployed_configurations(self):

src/s/a/sahara-HEAD/sahara/plugins/hdp/clusterspec.py   sahara(Download)
                service.validate(self, cluster)
            elif service.is_mandatory():
                raise ex.RequiredServiceMissingException(service.name)
 
    def get_deployed_configurations(self):