#NEWLINE# def validate_job_execution( self , cluster , job , data ) : #NEWLINE# #INDENT# if ( not self . edp_supported ( cluster . hadoop_version ) ) : #NEWLINE# #INDENT# raise exc . InvalidDataException ( _ ( 'Ambari plugin of {base} or higher required to run {type} jobs' ) . format ( base = EDPSparkEngine . edp_base_version , type = job . type ) ) #NEWLINE# #UNINDENT# spark_nodes_count = plugin_utils . get_instances_count ( cluster , p_common . SPARK_JOBHISTORYSERVER ) #NEWLINE# if ( data != 1 ) : #NEWLINE# #INDENT# raise pex . InvalidComponentCountException ( p_common . SPARK_JOBHISTORYSERVER , '1' , spark_nodes_count ) #NEWLINE# #UNINDENT# super ( EDPSparkEngine , self ) . validate_job_execution ( cluster , job , data )