#NEWLINE# @ staticmethod #NEWLINE# def test_run( test_case ) : #NEWLINE# #INDENT# job = WordCountJob ( use_hdfs = test_case . use_hdfs ) #NEWLINE# luigi . build ( [ job ] , local_scheduler = True ) #NEWLINE# c = read_wordcount_output ( job . output ( ) ) #NEWLINE# test_case . assertEqual ( int ( c [ 'jk' ] ) , 6 )