#NEWLINE# def _process( self , metric ) : #NEWLINE# #INDENT# '\n        We skip any locking code due to the fact that this is now a single\n        process per collector\n        ' #NEWLINE# try : #NEWLINE# #INDENT# self . queue . put ( self , block = False ) #NEWLINE# #UNINDENT# except Queue . Full : #NEWLINE# #INDENT# self . _throttle_error ( 'Queue full, check handlers for delays' )