anchor.diff:      ?assertMatch(?LIST_OK_ANS(ExpectedGetAns3), ?LIST(Id, {TimeSeriesId, MetricId}, Batch5)),
   
       % Add measurement in the middle of existing windows and verify windows
  -    Batch6 = update(Id, 4003, 0, Batch5),
  -    ExpectedGetAns4 = lists:sublist(ExpectedGetAns3, 9000),
  +    Batch6 = update(Id, 403, 0, Batch5),
  +    ExpectedGetAns4 = lists:sublist(ExpectedGetAns3, 900),
       ?assertMatch(?LIST_OK_ANS(ExpectedGetAns4), ?LIST(Id, {TimeSeriesId, MetricId}, Batch6)),
   
       % Add measurement after existing windows and verify windows
  -    Batch7 = update(Id, 6001, 0, Batch6),
  -    ExpectedGetAns5 = ExpectedGetAns4 ++ [{6001, 0}],
  +    Batch7 = update(Id, 601, 0, Batch6),
  +    ExpectedGetAns5 = ExpectedGetAns4 ++ [{601, 0}],
       ?assertMatch(?LIST_OK_ANS(ExpectedGetAns5), ?LIST(Id, {TimeSeriesId, MetricId}, Batch7)),
   
       % Add measurement that results in datastore documents splitting and verify windows
  -    Batch8 = update(Id, 8003, 0, Batch7),
  -    ExpectedGetAns6 = lists:sublist(ExpectedGetAns5, 7999) ++ [{8003, 0}] ++ lists:sublist(ExpectedGetAns5, 8000, 1002),
  +    Batch8 = update(Id, 803, 0, Batch7),
  +    ExpectedGetAns6 = lists:sublist(ExpectedGetAns5, 799) ++ [{803, 0}] ++ lists:sublist(ExpectedGetAns5, 800, 102),
       ?assertMatch(?LIST_OK_ANS(ExpectedGetAns6), ?LIST(Id, {TimeSeriesId, MetricId}, Batch8)),
   
  -    Batch9 = update(Id, 16003, 0, Batch8),
  -    ExpectedGetAns7 = lists:sublist(ExpectedGetAns6, 3999) ++ [{16003, 0}] ++ lists:sublist(ExpectedGetAns5, 4000, 3003),
  +    Batch9 = update(Id, 1603, 0, Batch8),
  +    ExpectedGetAns7 = lists:sublist(ExpectedGetAns6, 399) ++ [{1603, 0}] ++ lists:sublist(ExpectedGetAns5, 400, 303),
       ?assertMatch(?LIST_OK_ANS(ExpectedGetAns7), ?LIST(Id, {TimeSeriesId, MetricId}, Batch9)),
   
  -    Batch10 = update(Id, 24001, 0, Batch9),
  -    ExpectedGetAns8 = [{24001, 0} | ExpectedGetAns7],
  +    Batch10 = update(Id, 2401, 0, Batch9),
  +    ExpectedGetAns8 = [{2401, 0} | ExpectedGetAns7],
       ?assertMatch(?LIST_OK_ANS(ExpectedGetAns8), ?LIST(Id, {TimeSeriesId, MetricId}, Batch10)).
   
   
  
positive.code: 
  setup() ->
      % TODO VFS-8539 - set time_series_max_doc_size to 100
      application:set_env(?CLUSTER_WORKER_APP_NAME, time_series_max_doc_size, 2000),
      meck:new([datastore_doc_batch, datastore_doc], [passthrough, no_history]),
      meck:expect(datastore_doc_batch, init, fun() -> #{} end),
      meck:expect(datastore_doc, save, fun(_Ctx, Key, Doc, Batch) -> {{ok, Doc}, Batch#{Key => Doc}} end),
  
negative.code:     Id = datastore_key:new(),
      TimeSeriesId = <<"TS1">>,
      MetricId = <<"M1">>,
      MetricsConfig = #metric_config{resolution = 1, retention = 400, aggregator = max},
      ConfigMap = #{TimeSeriesId => #{MetricId => MetricsConfig}},
      Batch = init(Id, ConfigMap),
  
      % Prepare time series collection to be used in tests (batch stores collection)
      Measurements = lists:map(fun(I) -> {2 * I, 4 * I} end, lists:seq(1, 1000)),
      Batch2 = update_many(Id, Measurements, Batch),
  
      % Get and verify all windows
  