#NEWLINE# def _retry_nonexistent_zk_paths( configs ) : #NEWLINE# #INDENT# if configs : #NEWLINE# #INDENT# log . info ( ( 'Retrying %d configs with non-existent watched zookeeper path' % len ( configs ) ) ) #NEWLINE# failed = [ x for x in configs if ( not _place_watch_from_metaconfig ( x ) ) ] #NEWLINE# del _CONFIGS_WITH_NONEXISTENT_PATH [ : ] #NEWLINE# _CONFIGS_WITH_NONEXISTENT_PATH . extend ( failed )