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:          run_mover/7,
           unbalanced/2,
           eject_nodes/1,
           buckets_replication_statuses/0]).
  
  -export([wait_local_buckets_shutdown_complete/0]). % used via rpc:multicall
  
  
negative.code:                           end
                    end, [], Good),
  
              case FailedNodes ++ ReallyBadNodes of
                  [] ->
                      ok;
                  AllFailedNodes ->
                      {buckets_cleanup_failed, AllFailedNodes}
              end
      end.
  