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

Before Change

            new_cluster.from_json(ranks)

            if len(new_cluster.pods) == 0:
                time.sleep(1)
                continue

After Change

            new_cluster.from_json(value)

            with self._lock:
                self._new_cluster = new_cluster

            if self._is_world_changed():
                break

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

            time.sleep(3)

    @property
    def changed(self):
        with self._lock:

Instances