def apply_changes_from_source(self, source, changes):
        # XXX: Multiple nodes may report being primary for a dataset. Enforce
        # consistency here. See
        # https://clusterhq.atlassian.net/browse/FLOC-1303
        for change in changes:
            self._deployment_state = change.update_cluster_state(
                self._deployment_state
            )
        for change in changes:
            wiper = change.get_information_wipe()
            key = (wiper.__class__, wiper.key())
            self._information_wipers = self._information_wipers.set(
                key, _WiperAndSource(wiper=wiper, source=source)
            )
Apply some changes to the cluster state.
dataset/ETHPy150Open ClusterHQ/flocker/flocker/control/_clusterstate.py/ClusterStateService.apply_changes_from_source