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:     {noreply, NewState :: #state{}, timeout() | hibernate} |
      {stop, Reason :: term(), Reply :: term(), NewState :: #state{}} |
      {stop, Reason :: term(), NewState :: #state{}}).
  handle_call(Task = ?TASK(#deletion_task{}, _ReportId), From, State = #state{
      active_tasks = ActiveTasks,
      max_active_tasks = MaxActiveTasks
  }) when ActiveTasks < MaxActiveTasks ->
      gen_server2:reply(From, ok),
      handle_cast(Task, State);
  handle_call(Task = ?TASK(#deletion_task{}, _ReportId), From, State = #state{queue = Queue}) ->
      % queue is full, don't reply so that the calling process is blocked
      {noreply, State#state{queue = queue:in({From, Task}, Queue)}};
  handle_call(Request, From, State) ->
      gen_server2:reply(From, ok),
      handle_cast(Request, State).
  
  %%--------------------------------------------------------------------
  %% @private
  