anchor.diff:          }, Acc) ->
               WindowsAcc = maps:get(?MAX_FILE_SIZE_TS_NAME, Acc, #{}),
   
  -            Acc#{?MAX_FILE_SIZE_TS_NAME => #{?MAX_FILE_SIZE_TS_NAME => max_window(
  -                ?MAX_FILE_SIZE_METRIC_WINDOW(Timestamp, Value),
  -                maps:get(?MAX_FILE_SIZE_TS_NAME, WindowsAcc, [])
  -            )}};
  +            Acc#{?MAX_FILE_SIZE_TS_NAME => #{
  +                ?MAX_FILE_SIZE_TS_NAME => insert_window_to_metric_with_max_aggregator(
  +                    ?MAX_FILE_SIZE_METRIC_WINDOW(Timestamp, Value),
  +                    maps:get(?MAX_FILE_SIZE_TS_NAME, WindowsAcc, [])
  +                )
  +            }};
   
           (_, Acc) ->
               % other measurements should be ignored as they are not mapped to any ts
  
positive.code:         {ok, ObjectId} = file_id:guid_to_objectid(Guid),
          #{<<"file_id">> => ObjectId}
      end, FileObjects),
      SrcStoreSchemaDraft = ?SRC_LIST_STORE_SCHEMA_DRAFT(IteratedItemDataSpec, IteratedItems),
  
      DstStoreSchemaId = <<"dst_st">>,
      DstStoreSchemaDraft = #atm_store_schema_draft{
          id = DstStoreSchemaId,
          type = tree_forest,
          config = #atm_tree_forest_store_config{item_data_spec = #atm_data_spec{type = atm_file_type}}
      },
  
      map_results_to_dst_store_test_base(
          [SrcStoreSchemaDraft, DstStoreSchemaDraft],
          IteratedItemDataSpec,
          IteratedItems,
          DstStoreSchemaId,
          tree_forest,
          #atm_tree_forest_store_content_update_options{function = append}
      ).
  
  
  map_results_to_workflow_audit_log_store_test() ->
  
negative.code:     IteratedItems = gen_random_time_series_measurements(),
      SrcStoreSchemaDraft = ?SRC_LIST_STORE_SCHEMA_DRAFT(IteratedItemDataSpec, IteratedItems),
  
      map_results_to_store_test_base(#map_results_to_store_test_spec{
          global_store_schema_drafts = [SrcStoreSchemaDraft],
          iterated_item_spec = IteratedItemDataSpec,
          iterated_items = IteratedItems,
          dst_store_schema_id = ?CURRENT_TASK_TIME_SERIES_STORE_SCHEMA_ID,
          dst_store_type = time_series,
          dst_store_update_options = #atm_time_series_store_content_update_options{
              dispatch_rules = ?ATM_TIME_SERIES_DISPATCH_RULES
          }
      }).
  
  
  %% @private
  -spec map_results_to_store_test_base(map_results_to_store_test_spec()) -> ok.
  map_results_to_store_test_base(#map_results_to_store_test_spec{
      global_store_schema_drafts = StoreSchemaDrafts,
      iterated_item_spec = IteratedItemDataSpec,
      iterated_items = IteratedItems,
      dst_store_schema_id = DstStoreSchemaId,
      dst_store_type = DstStoreType,
      dst_store_update_options = DstStoreContentUpdateOptions
  }) ->
      atm_workflow_execution_test_runner:run(#atm_workflow_execution_test_spec{
          provider = ?PROVIDER_SELECTOR,
          user = ?USER_SELECTOR,
  