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:     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),
  