#NEWLINE# def put( self , data , priority = TaskPriority . DEFAULT , view = None , block = True , timeout = None ) : #NEWLINE# #INDENT# with self . lock_put : #NEWLINE# #INDENT# _logger . debug ( 'putting in %s: %s' , self . name , repr ( data ) ) #NEWLINE# priority = self . calculate_priority ( view , priority ) #NEWLINE# super ( ) . put ( ( priority , json . dumps ( data ) ) , block , timeout )