ed9fb224f3aa4336d066cbbe4b9abf26b24f8535,python/edl/utils/watcher.py,Watcher,_watcher,#Watcher#,58

Before Change

            servers = self._etcd.get_service(ETCD_POD_RANK)
            ranks = {}
            for s in servers:
                ranks[int(s.server)] = s.info
            //logger.info("ranks:{}".format(ranks))

            new_cluster = Cluster()

After Change

            with self._lock:
                // update the cluster info.
                self._cluster = copy.copy(self._new_cluster)

            time.sleep(3)

    @property

Instances