anchor.diff:      Nodes = State#state.nodes,
       TasksHashesSet =
           dict:fold(
  -          fun (_Node, NodeInfo, Set) ->
  +          fun (TaskNode, NodeInfo, Set) ->
                     lists:foldl(
                       fun (Task, Set0) ->
                               case proplists:get_value(type, Task) of
  
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
  