anchor.diff:  -record(state, {
       space_id :: od_space:id(),
       active_tasks = 0 :: non_neg_integer(),
  -    queues = #{} :: #{replica_deletion:report_id() => queue:queue()},
  -    ids_queue = queue:new() :: queue:queue(),
  +    max_active_tasks = ?MAX_ACTIVE_TASKS,
       ids_to_cancel = gb_sets:new() :: gb_sets:set(),
  -    max_active_tasks = ?MAX_ACTIVE_TASKS
  +    queue = queue:new() :: queue:queue()
   }).
   
   -record(deletion_task, {
  
positive.code:     id :: replica_deletion:report_id()
  }).
  
  
  -type task() :: #task{}.
  -type deletion_task() :: #deletion_task{}.
  
  %%TODO VFS-4625 handle too long queue of tasks and return error
  
  %%%===================================================================
  %%% API
  
negative.code:             ok = handle_task(Task, SpaceId)
      end,
      {noreply, State#state{active_tasks = ActiveTasks + 1}, ?DIE_AFTER};
  handle_cast(?FINISHED, State = #state{
      active_tasks = ActiveTasks,
      queue = Queue
  }) ->
      case queue:out(Queue) of
          {empty, Queue} ->
              State2 = State#state{active_tasks = ActiveTasks - 1},
              {noreply, State2, ?DIE_AFTER};
          {{value, {From, Task}}, Queue2} ->
              gen_server2:reply(From, ok),
              State2 = State#state{
                  queue = Queue2,
                  active_tasks = ActiveTasks - 1
              },
              handle_cast(Task, State2)
  