#NEWLINE# def test_impala_step_with_all_fields( self ) : #NEWLINE# #INDENT# test_step_config = ( ( ( ( 'Name=ImpalaWithAllFields,' + 'Type=Impala,' ) + self . IMPALA_BASIC_ARGS ) + ',' ) + 'ActionOnFailure=CANCEL_AND_WAIT' ) #NEWLINE# cmd = ( self . prefix + test_step_config ) #NEWLINE# expected_result = { #NEWLINE# #INDENT# 'JobFlowId' : 'j-ABC' , #NEWLINE# 'Steps' : [ { #NEWLINE# #INDENT# 'Name' : 'ImpalaWithAllFields' , #NEWLINE# 'ActionOnFailure' : 'CANCEL_AND_WAIT' , #NEWLINE# 'HadoopJarStep' : self . IMPALA_BASIC_SCRIPT_RUNNER_STEP , #NEWLINE# #UNINDENT# } ] , #NEWLINE# #UNINDENT# } #NEWLINE# self . assert_params_for_ami_and_release_based_clusters ( cmd = cmd , expected_result = expected_result , expected_result_release = None )