#NEWLINE# def test_SPARK_SUBMIT_SCRIPT_RUNNER_STEP( self ) : #NEWLINE# #INDENT# cmd = ( ( self . prefix + 'Type=SPARK,' ) + self . SPARK_SUBMIT_BASIC_ARGS ) #NEWLINE# expected_result = { #NEWLINE# #INDENT# 'JobFlowId' : 'j-ABC' , #NEWLINE# 'Steps' : [ { #NEWLINE# #INDENT# 'Name' : 'Spark application' , #NEWLINE# 'ActionOnFailure' : 'CONTINUE' , #NEWLINE# 'HadoopJarStep' : self . SPARK_SUBMIT_SCRIPT_RUNNER_STEP , #NEWLINE# #UNINDENT# } ] , #NEWLINE# #UNINDENT# } #NEWLINE# expected_result_release = copy . deepcopy ( expected_result ) #NEWLINE# expected_result_release [ 'Steps' ] [ 0 ] [ 'HadoopJarStep' ] = self . SPARK_SUBMIT_COMMAND_RUNNER_STEP #NEWLINE# self . assert_params_for_ami_and_release_based_clusters ( cmd = cmd , expected_result = expected_result , expected_result_release = expected_result_release )