#NEWLINE# def _readStatsAndLogging( self , callback , ownerId ) : #NEWLINE# #INDENT# items = None #NEWLINE# for attempt in retry_sdb ( ) : #NEWLINE# #INDENT# with attempt : #NEWLINE# #INDENT# items = list ( self . filesDomain . select ( consistent_read = True , query = ( "select * from `%s` where ownerID='%s'" % ( self . filesDomain . name , str ( info ) ) ) ) ) #NEWLINE# #UNINDENT# #UNINDENT# assert ( items is not None ) #NEWLINE# for item in items : #NEWLINE# #INDENT# info = self . FileInfo . fromItem ( item ) #NEWLINE# with info . downloadStream ( ) as readable : #NEWLINE# #INDENT# callback ( readable ) #NEWLINE# #UNINDENT# ( yield info )