#NEWLINE# def _inner_start( self ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# while True : #NEWLINE# #INDENT# async_result = self . client . handler . async_result ( ) #NEWLINE# self . children = self . client . retry ( self . client . get_children , self . path , partial ( self . _children_watcher , async_result ) ) #NEWLINE# self . client . handler . sleep_func ( exc . time_boundary ) #NEWLINE# if self . children_changed . is_set ( ) : #NEWLINE# #INDENT# self . children_changed . clear ( ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# break #NEWLINE# #UNINDENT# #UNINDENT# self . asy . set ( ( self . children , async_result ) ) #NEWLINE# #UNINDENT# except Exception as exc : #NEWLINE# #INDENT# self . asy . set_exception ( exc )