#NEWLINE# @ staticmethod #NEWLINE# def test_map_only( test_case ) : #NEWLINE# #INDENT# job = MapOnlyJob ( use_hdfs = test_case . use_hdfs ) #NEWLINE# luigi . build ( [ job ] , local_scheduler = True ) #NEWLINE# c = [ ] #NEWLINE# for line in job . output ( ) . open ( 'r' ) : #NEWLINE# #INDENT# c . append ( line . strip ( ) ) #NEWLINE# #UNINDENT# test_case . assertEqual ( c [ 0 ] , 'kj' ) #NEWLINE# test_case . assertEqual ( c [ 4 ] , 'ljoi' )