#NEWLINE# def test_pig_step_with_all_fields( self ) : #NEWLINE# #INDENT# test_step_config = ( ( ( ( 'Name=PigWithAllFields,' + 'Type=Pig,' ) + self . PIG_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' : 'PigWithAllFields' , #NEWLINE# 'ActionOnFailure' : 'CANCEL_AND_WAIT' , #NEWLINE# 'HadoopJarStep' : self . PIG_DEFAULT_SCRIPT_RUNNER_STEP , #NEWLINE# #UNINDENT# } ] , #NEWLINE# #UNINDENT# } #NEWLINE# expected_result_release = copy . deepcopy ( expected_result ) #NEWLINE# expected_result_release [ 'Steps' ] [ 0 ] [ 'HadoopJarStep' ] = self . PIG_DEFAULT_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 )