anchor.diff:  complete_service_failover(Config, Service) ->
       true = ns_cluster_membership:service_has_pending_failover(Config, Service),
   
  -    RV = case lists:member(Service, ns_cluster_membership:topology_aware_services()) of
  +    TopologyAwareServices = ns_cluster_membership:topology_aware_services(),
  +    RV = case lists:member(Service, TopologyAwareServices) of
                true ->
                    complete_topology_aware_service_failover(Config, Service);
                false ->
  
positive.code: 
      case RV of
          ok ->
              ns_cluster_membership:service_clear_pending_failover(Service);
          _ ->
              ok
      end,
  
      RV.
  
  complete_topology_aware_service_failover(Config, Service) ->
      NodesLeft = ns_cluster_membership:get_service_map(Config, Service),
  
negative.code:     end.
  
  orchestrate_service_failover(Service, Nodes) ->
      leader_activities:run_activity(
        {service_janitor, Service, orchestrate_service_failover}, {all, Nodes},
        fun () ->
                misc:with_trap_exit(
                  ?cut(do_orchestrate_service_failover(Service, Nodes)))
        end).
  
  do_orchestrate_service_failover(Service, Nodes) ->
      {Pid, MRef} = service_rebalancer:spawn_monitor_failover(Service, Nodes),
  