#NEWLINE# def test_plugin_edp_engine( self ) : #NEWLINE# #INDENT# cluster_dict = { #NEWLINE# #INDENT# 'name' : 'cluster' , #NEWLINE# 'plugin_name' : 'cdh' , #NEWLINE# 'hadoop_version' : '5.5.0' , #NEWLINE# 'default_image_id' : 'image' , #NEWLINE# #UNINDENT# } #NEWLINE# cluster = conductor . cluster_create ( context . ctx ( ) , cluster_dict ) #NEWLINE# plugin = pb . PLUGINS . get_plugin ( cluster . plugin_name ) #NEWLINE# self . assertIsInstance ( plugin . get_edp_engine ( cluster , edp . JOB_TYPE_SPARK ) , engine . SparkJobEngine )