#NEWLINE# @ mock . patch ( 'sahara.conductor.API.job_get' ) #NEWLINE# def test_job_type_supported( self , job_get ) : #NEWLINE# #INDENT# ( job , job_exec ) = u . create_job_exec ( edp . JOB_TYPE_PIG ) #NEWLINE# job_get . return_value = job #NEWLINE# self . assertIsNotNone ( job_manager . get_job_engine ( u . create_cluster ( ) , self ) ) #NEWLINE# job . type = 'unsupported_type' #NEWLINE# self . assertIsNone ( job_manager . get_job_engine ( u . create_cluster ( ) , job_exec ) )