anchor.diff:      NumBuckets = length(BucketConfigs),
       ?rebalance_debug("BucketConfigs = ~p", [BucketConfigs]),
   
  -    maybe_cleanup_old_buckets(KeepNodes),
  +    case maybe_cleanup_old_buckets(KeepNodes) of
  +        ok ->
  +            ok;
  +        Error ->
  +            exit(Error)
  +    end,
   
   
       %% Eject failed nodes first so they don't cause trouble
  
positive.code:         {_, _, DownNodes} when DownNodes =/= [] ->
              ?rebalance_error("Failed to cleanup old buckets on some nodes: ~p",
                               [DownNodes]),
              exit({buckets_cleanup_failed, DownNodes});
          {Good, ReallyBad, []} ->
              case ReallyBad of
                  [] ->
                      ok;
                  _ ->
                      ?rebalance_error(
                         "Failed to cleanup old buckets on some nodes: ~n~p",
                         [ReallyBad]),
                      ReallyBadNodes =
                          lists:map(fun ({Node, _}) -> Node end, ReallyBad),
                      exit({buckets_cleanup_failed, ReallyBadNodes})
              end,
  
              FailedNodes =
                  lists:foldl(
  
negative.code:                           end
                    end, [], Good),
  
              case FailedNodes ++ ReallyBadNodes of
                  [] ->
                      ok;
                  AllFailedNodes ->
                      {buckets_cleanup_failed, AllFailedNodes}
              end
      end.
  