#NEWLINE# @ mock . patch ( 'luigi.contrib.hadoop.run_and_track_hadoop_job' ) #NEWLINE# def test_run( self , run_and_track_hadoop_job ) : #NEWLINE# #INDENT# success = luigi . run ( [ 'MyHiveTask' , '--param' , 'foo' , '--local-scheduler' , '--no-lock' ] ) #NEWLINE# self . assertTrue ( success ) #NEWLINE# self . assertEqual ( 'hive' , run_and_track_hadoop_job . call_args [ 0 ] [ 0 ] [ 0 ] )