#NEWLINE# def _expire_error_stream( self , stream ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# self . db . set_stream_state ( stream , StreamState . expire_error ) #NEWLINE# #UNINDENT# except LockError : #NEWLINE# #INDENT# logger . error ( ( "Stream %s locked while trying to set 'expire_error' state! This should not happen." % stream . id ) )