#NEWLINE# def test_all_step_types( self ) : #NEWLINE# #INDENT# test_step_config = ( ( ( ( ( ( ( ( 'Jar=s3://mybucket/mytest.jar ' + ' Type=Streaming,' ) + self . STREAMING_ARGS ) + ' Type=Hive,' ) + self . HIVE_BASIC_ARGS ) + ' Type=Pig,' ) + self . PIG_BASIC_ARGS ) + ' Type=Impala,' ) + self . IMPALA_BASIC_ARGS ) #NEWLINE# cmd = ( self . prefix + test_step_config ) #NEWLINE# expected_result = { #NEWLINE# #INDENT# 'JobFlowId' : 'j-ABC' , #NEWLINE# 'Steps' : [ { #NEWLINE# #INDENT# 'Name' : 'Custom JAR' , #NEWLINE# 'ActionOnFailure' : 'CONTINUE' , #NEWLINE# 'HadoopJarStep' : { #NEWLINE# #INDENT# 'Jar' : 's3://mybucket/mytest.jar' , #NEWLINE# #UNINDENT# } , #NEWLINE# #UNINDENT# } , { #NEWLINE# #INDENT# 'Name' : 'Streaming program' , #NEWLINE# 'ActionOnFailure' : 'CONTINUE' , #NEWLINE# 'HadoopJarStep' : self . STREAMING_HADOOP_SCRIPT_RUNNER_STEP , #NEWLINE# #UNINDENT# } , { #NEWLINE# #INDENT# 'Name' : 'Hive program' , #NEWLINE# 'ActionOnFailure' : 'CONTINUE' , #NEWLINE# 'HadoopJarStep' : self . HIVE_DEFAULT_SCRIPT_RUNNER_STEP , #NEWLINE# #UNINDENT# } , { #NEWLINE# #INDENT# 'Name' : 'Pig program' , #NEWLINE# 'ActionOnFailure' : 'CONTINUE' , #NEWLINE# 'HadoopJarStep' : self . PIG_DEFAULT_SCRIPT_RUNNER_STEP , #NEWLINE# #UNINDENT# } , { #NEWLINE# #INDENT# 'Name' : 'Impala program' , #NEWLINE# 'ActionOnFailure' : 'CONTINUE' , #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 )