anchor.diff:              ok
       end.
   
  -  try_nodes_ready([Node1 | _Nodes], 0, _SleepMs) ->
  +try_nodes_ready([Node1 | _Nodes], 0, _SleepMs) ->
         lager:info("Nodes not ready after initial plan/commit, retrying"),
         plan_and_commit(Node1);
     try_nodes_ready(Nodes, N, SleepMs) ->
  
positive.code: 
  plan_and_commit(Node) ->
      timer:sleep(5000),
      lager:info("planning and commiting cluster join"),
      case rpc:call(Node, riak_core_claimant, plan, []) of
          {error, ring_not_ready} ->
              lager:info("plan: ring not ready"),
  
negative.code: 
              {ok, _} = rpc:call(Node, application, ensure_all_started, [antidote]),
              Node;
          {error, _, Node} ->
              ct_slave:stop(Name),
              wait_until_offline(Node),
              start_suite(Name, Config)
  