def get_edp_engine(self, cluster, job_type):
        if job_type in edp_engine.EdpOozieEngine.get_supported_job_types():
            return edp_engine.EdpOozieEngine(cluster)
        return None
dataset/ETHPy150Open openstack/sahara/sahara/plugins/vanilla/v2_7_1/versionhandler.py/VersionHandler.get_edp_engine/original