anchor.diff:      handle_results(RVs).
   
   maybe_complete_pending_failover(Config, Service) ->
  +    {ok, RV} =
  +        leader_activities:run_activity(
  +          {service_janitor, Service, maybe_complete_pending_failover},
  +          majority,
  +          fun () ->
  +                  {ok, maybe_complete_pending_failover_body(Config, Service)}
  +          end,
  +          [quiet]),
  +
  +    RV.
  +
  +maybe_complete_pending_failover_body(Config, Service) ->
       case ns_cluster_membership:service_has_pending_failover(Config, Service) of
           true ->
               ?log_debug("Found unfinished failover for service ~p", [Service]),
  
positive.code: 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
               true ->
                   complete_topology_aware_service_failover(Config, Service);
               false ->
  
negative.code: 
      case RV of
          ok ->
              clear_pending_failover(Service);
          _ ->
              ok
      end,
  
      RV.
  
  clear_pending_failover(Service) ->
      ns_cluster_membership:service_clear_pending_failover(Service).
  
  complete_topology_aware_service_failover(Config, Service) ->
      NodesLeft = ns_cluster_membership:get_service_map(Config, Service),
  