anchor.diff:      proc_lib:init_ack({ok, self()}),
   
       ale:info(?USER_LOGGER, "Starting vbucket moves for graceful failover of ~p", [Node]),
  -    do_pre_rebalance_config_sync(ns_node_disco:nodes_wanted()),
  +    pull_and_push_config(ns_node_disco:nodes_wanted()),
       AllBucketConfigs = ns_bucket:get_buckets(),
   
       %% yes we're doing it second time after config sync. In case
  
positive.code: sanitize(Config) ->
      misc:rewrite_key_value_tuple(sasl_password, "*****", Config).
  
  do_pre_rebalance_config_sync(Nodes) ->
      %% TODO: pull config reliably here as well.
      %%
      %% And after we have that, make sure recovery, rebalance and
  
negative.code: 
      ns_cluster_membership:activate(KeepNodes),
  
      pull_and_push_config(EjectNodesAll ++ KeepNodes),
  
      %% Eject failed nodes first so they don't cause trouble
      FailedNodes = FailedNodesAll -- [node()],
  