#NEWLINE# def test_hadoop_extra_args_comes_first( self ) : #NEWLINE# #INDENT# job = MRWordCount ( [ '-r' , self . RUNNER , '--cmdenv' , 'FOO=bar' , '--hadoop-arg' , '-libjar' , '--hadoop-arg' , 'qux.jar' , '--jobconf' , 'baz=qux' , '--partitioner' , 'java.lang.Object' ] ) #NEWLINE# job . HADOOP_INPUT_FORMAT = 'FooInputFormat' #NEWLINE# job . HADOOP_OUTPUT_FORMAT = 'BarOutputFormat' #NEWLINE# with job . make_runner ( ) as runner : #NEWLINE# #INDENT# hadoop_args = runner . _hadoop_args_for_step ( 0 ) #NEWLINE# self . assertEqual ( hadoop_args [ : 2 ] , [ '-libjar' , 'qux.jar' ] ) #NEWLINE# self . assertEqual ( len ( hadoop_args ) , 12 )