#NEWLINE# def _args_for_step( self , step_num ) : #NEWLINE# #INDENT# step = self . _get_step ( step_num ) #NEWLINE# if ( step [ 'type' ] == 'streaming' ) : #NEWLINE# #INDENT# return self . _args_for_streaming_step ( step ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( step [ 'type' ] == 'jar' ) : #NEWLINE# #INDENT# return self . _args_for_jar_step ( step_num ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# raise AssertionError ( ( 'Bad step type: %r' % ( step [ 'type' ] , ) ) )