#NEWLINE# def _stream_task_log_dirs( self , application_id = None , output_dir = None ) : #NEWLINE# #INDENT# 'Yield lists of directories to look for the task logs in.' #NEWLINE# for log_dir in unique ( self . _hadoop_log_dirs ( output_dir = output_dir ) ) : #NEWLINE# #INDENT# if application_id : #NEWLINE# #INDENT# path = self . fs . join ( log_dir , 'userlogs' , application_id ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# path = self . fs . join ( log_dir , 'userlogs' ) #NEWLINE# #UNINDENT# if self . fs . exists ( path ) : #NEWLINE# #INDENT# log . info ( ( 'Looking for task syslogs in %s...' % path ) ) #NEWLINE# ( yield [ path ] )