anchor.diff:  
   -spec notify_processed_file(od_space:id(), batch_id()) -> ok.
   notify_processed_file(SpaceId, BatchId) ->
  -    {_ARId, BatchNum} = from_batch_id(BatchId),
  +    {_AutocleaningRunId, BatchNum} = unpack_batch_id(BatchId),
       gen_server2:cast(?SERVER(SpaceId), ?FILE_PROCESSED(BatchNum)).
   
   %%%===================================================================
  
positive.code:             undefined ->
                  ScheduledNumIn;
              {FileUuid, Provider, Blocks, VV} ->
                  BatchId = to_batch_id(ARId, BatchNum),
                  schedule_replica_deletion_task(FileUuid, Provider, Blocks, VV, BatchId, SpaceId),
                  ScheduledNumIn + 1
          end
  
negative.code:     ?run_and_catch_errors(fun() ->
          autocleaning_run:mark_completed(ARId),
          replica_deletion_master:cancelling_finished(ARId, SpaceId),
          ?debug("Auto-cleaning run ~p of space ~p finished", [ARId, SpaceId]),
          {stop, normal, State}
      end, State);
  handle_cast(_Request, State) ->
  