#NEWLINE# @ mock . patch ( 'subprocess.check_call' ) #NEWLINE# @ mock . patch ( 'luigi.contrib.hadoop.run_and_track_hadoop_job' ) #NEWLINE# def test_scalding( self , check_call , track_job ) : #NEWLINE# #INDENT# success = luigi . run ( [ 'MyScaldingTask' , '--scala-source' , self . scala_source , '--local-scheduler' , '--no-lock' ] ) #NEWLINE# self . assertTrue ( success )