anchor.diff:  
               ?assertEqual(ok, rpc:call(Worker, ?MEM_DRV(Model), delete, [MemCtx, Key])),
               assert_key_not_in_memory(Worker, Model, Key),
  -            ?assertMatch({ok, ExpectedMap}, rpc:call(Worker, Model, time_series_collection_list_windows, [Id, maps:keys(ExpectedMap), #{}]))
  +            ?assertMatch({ok, ExpectedMap},
  +                rpc:call(Worker, Model, time_series_collection_list_windows, [Id, maps:keys(ExpectedMap), #{}]))
           end, Keys)
       end, ?TEST_CACHED_MODELS).
   
  
positive.code:                     lists:reverse(Measurements), maps:get(Retention, ExpectedWindowsCounts))}
              end, Acc, MetricsConfigs)
          end, #{}, ConfigMap),
          ?assertMatch({ok, ExpectedMap}, rpc:call(Worker, Model, time_series_collection_list_windows, [Id, #{}])),
  
          % Test getting all metrics
          Keys = get_all_keys(Worker, ?MEM_DRV(Model), ?MEM_CTX(Model)) -- InitialKeys,
  
          % Verify if delete clears all documents from datastore
          ?assertMatch(ok, rpc:call(Worker, Model, time_series_collection_delete, [Id])),
          lists:foreach(fun(Key) ->
              assert_key_not_in_memory(Worker, Model, Key)
          end, Keys)
      end, ?TEST_MODELS).
  
  
  
negative.code:             ok;
          Driver ->
              Ctx = datastore_multiplier:extend_name(Key, ?MEM_CTX(Model)),
              ?assertMatch({error, not_found}, rpc:call(Worker, Driver, get, [Ctx, Key]))
      end.
  
  assert_on_disc(Worker, Model, Key) ->
  