#NEWLINE# def remove_cb( self , key , value , org_key , org_value , org_cb ) : #NEWLINE# #INDENT# ' remove callback, on error retry after flush_timeout\n        ' #NEWLINE# if ( key == True ) : #NEWLINE# #INDENT# if org_cb : #NEWLINE# #INDENT# org_cb ( key = org_key , value = True ) #NEWLINE# #UNINDENT# if ( key in self . localstore_sets ) : #NEWLINE# #INDENT# if self . localstore_sets [ key ] [ '+' ] : #NEWLINE# #INDENT# self . localstore_sets [ key ] [ '-' ] = set ( [ ] ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# del self . localstore_sets [ key ] #NEWLINE# #UNINDENT# #UNINDENT# self . reset_flush_timeout ( ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# _log . error ( ( 'Failed to update %s' % key ) ) #NEWLINE# if org_cb : #NEWLINE# #INDENT# org_cb ( key = org_key , value = False ) #NEWLINE# #UNINDENT# #UNINDENT# self . trigger_flush ( )