#NEWLINE# def test_streaming_step_with_default_fields( self ) : #NEWLINE# #INDENT# cmd = ( ( DEFAULT_CMD + '--steps Type=Streaming,' ) + STREAMING_ARGS ) #NEWLINE# result = copy . deepcopy ( DEFAULT_RESULT ) #NEWLINE# result [ 'Steps' ] = [ { #NEWLINE# #INDENT# 'Name' : 'Streaming program' , #NEWLINE# 'ActionOnFailure' : 'CONTINUE' , #NEWLINE# 'HadoopJarStep' : STREAMING_HADOOP_JAR_STEP , #NEWLINE# #UNINDENT# } ] #NEWLINE# self . assert_params_for_cmd ( cmd , cmd )