3939from opentelemetry .sdk .metrics ._internal .sdk_configuration import (
4040 SdkConfiguration ,
4141)
42+ from opentelemetry .sdk .metrics ._internal .view import _default_reservoir_factory
4243from opentelemetry .sdk .metrics .export import AggregationTemporality
4344from opentelemetry .sdk .metrics .view import (
4445 DefaultAggregation ,
@@ -296,7 +297,7 @@ def test_collect_resets_start_time_unix_nano(self, mock_time_ns):
296297 )
297298 )
298299 view_instrument_match ._view ._aggregation ._create_aggregation .assert_called_with (
299- instrument , {"foo" : "bar0" }, start_time_unix_nano
300+ instrument , {"foo" : "bar0" }, _default_reservoir_factory , start_time_unix_nano
300301 )
301302 collection_start_time_unix_nano = time_ns ()
302303 collected_data_points = view_instrument_match .collect (
@@ -316,7 +317,7 @@ def test_collect_resets_start_time_unix_nano(self, mock_time_ns):
316317 )
317318 )
318319 view_instrument_match ._view ._aggregation ._create_aggregation .assert_called_with (
319- instrument , {"foo" : "bar1" }, 1
320+ instrument , {"foo" : "bar1" }, _default_reservoir_factory , 1
320321 )
321322 collection_start_time_unix_nano = time_ns ()
322323 collected_data_points = view_instrument_match .collect (
@@ -338,7 +339,7 @@ def test_collect_resets_start_time_unix_nano(self, mock_time_ns):
338339 )
339340 )
340341 view_instrument_match ._view ._aggregation ._create_aggregation .assert_called_with (
341- instrument , {"foo" : "bar" }, 2
342+ instrument , {"foo" : "bar" }, _default_reservoir_factory , 2
342343 )
343344 # No new calls to _create_aggregation because attributes remain the same
344345 view_instrument_match .consume_measurement (
0 commit comments