anchor.diff:      WarmupTasks = [[{status, running} | KV]
                      || KV <- WarmupTasks0],
   
  -    PreRebalanceTasks1 = SampleBucketTasks ++ WarmupTasks ++ XDCRTasks ++ PreRebalanceTasks0,
  +    MaybeCollectTask = pick_latest_cluster_collect_task(AllNodeTasks),
  +
  +    PreRebalanceTasks1 = SampleBucketTasks ++ WarmupTasks ++ XDCRTasks ++ PreRebalanceTasks0 ++ MaybeCollectTask,
   
       PreRebalanceTasks2 =
           lists:sort(
  
positive.code: task_maybe_add_cancel_uri(_, Value, _) ->
      Value.
  
  do_build_tasks_list(NodesDict, NeedNodeP, PoolId, AllRepDocs) ->
      AllRawTasks0 =
          dict:fold(
            fun (Node, NodeInfo, Acc) ->
                    case NeedNodeP(Node) of
                        true ->
                            NodeTasks = proplists:get_value(local_tasks, NodeInfo, []),
                            [NodeTasks | Acc];
                        false ->
                            Acc
                    end
            end, [], NodesDict),
  
      AllRawTasks = lists:append(AllRawTasks0),
  
      TasksDict =
          lists:foldl(
  
negative.code:                                       erlang:phash2({warming_up,
                                                       lists:keyfind(bucket, 1, Task)}),
                                        Set0);
                                  cluster_logs_collect ->
                                      sets:add_element(
                                        erlang:phash2({cluster_logs_collect,
                                                       TaskNode,
                                                       lists:keydelete(perNode, 1, Task)}),
                                        Set0);
                                  _ ->
                                      Set0
                              end
  