anchor.diff:                    ["pools", PoolId, "buckets", Bucket, "recoveryStatus"],
                     [{recovery_uuid, RecoveryUUID}]),
   
  -            [{struct, [{type, recovery},
  -                       {bucket, list_to_binary(Bucket)},
  -                       {uuid, RecoveryUUID},
  -                       {recommendedRefreshPeriod, 10.0},
  -
  -                       {stopURI, StopURI},
  -                       {commitVBucketURI, CommitURI},
  -                       {recoveryStatusURI, RecoveryStatusURI}]}]
  +            [[{type, recovery},
  +              {bucket, list_to_binary(Bucket)},
  +              {uuid, RecoveryUUID},
  +              {recommendedRefreshPeriod, 10.0},
  +
  +              {stopURI, StopURI},
  +              {commitVBucketURI, CommitURI},
  +              {recoveryStatusURI, RecoveryStatusURI}]]
       end.
   
   process_heartbeat(Node, Status, State) ->
  
positive.code:     [[{status, running} | KV] || KV <- WarmupTasks0].
  
  build_rebalance_task(Timeout) ->
      case (catch ns_orchestrator:rebalance_progress_full(Timeout)) of
          {running, PerNode} ->
              DetailedProgress = get_detailed_progress(),
  
negative.code:                   end
            end, dict:new(), AllRawTasks),
  
      CompactionAndIndexingTasks =
          dict:fold(fun ({xdcr, _}, _, Acc) -> Acc;
                        (Signature, Value, Acc) ->
                            Value1 = task_operation(finalize, Signature, Value),
                            FinalValue = task_maybe_add_cancel_uri(Signature, Value1, PoolId),
                            [FinalValue | Acc]
                    end, [], TasksDict),
  
      XDCRTasks = build_xdcr_tasks(TasksDict, AllRepDocs),
      SampleBucketTasks = build_sample_buckets_tasks(AllRawTasks),
      WarmupTasks = build_warmup_tasks(AllRawTasks),
      CollectTask = pick_latest_cluster_collect_task(AllNodeTasks),
      RebalanceTask = build_rebalance_task(RebStatusTimeout),
      RecoveryTask = build_recovery_task(PoolId),
  
      Tasks0 = lists:append([CompactionAndIndexingTasks, XDCRTasks,
                             SampleBucketTasks, WarmupTasks, CollectTask,
                             RebalanceTask, RecoveryTask]),
  
      Tasks1 =
          lists:sort(
            fun (A, B) ->
                    TypeA = task_type(A),
  