#NEWLINE# def _watch_session( self , state ) : #NEWLINE# #INDENT# if ( state == KazooState . LOST ) : #NEWLINE# #INDENT# self . _session_expired = True #NEWLINE# self . wake_event . set ( ) #NEWLINE# return True