#NEWLINE# def _wipe_expired( self ) : #NEWLINE# #INDENT# '\n        Clear any expired state from memory.\n        ' #NEWLINE# current_time = datetime . utcfromtimestamp ( self . _clock . seconds ( ) ) #NEWLINE# evolver = self . _information_wipers . evolver ( ) #NEWLINE# for ( key , wipe ) in self . _information_wipers . items ( ) : #NEWLINE# #INDENT# last_activity = wipe . last_activity ( ) #NEWLINE# if ( ( current_time - last_activity ) >= EXPIRATION_TIME ) : #NEWLINE# #INDENT# self . _deployment_state = wipe . update_cluster_state ( key . _deployment_state ) #NEWLINE# evolver . remove ( key ) #NEWLINE# #UNINDENT# #UNINDENT# self . _information_wipers = evolver . persistent ( )