@@ -656,51 +656,51 @@ def collect(
656
656
if aggregation_temporality is AggregationTemporality .CUMULATIVE :
657
657
658
658
start_time_unix_nano = self ._previous_start_time_unix_nano
659
- sum_ = current_point . sum + self ._previous_sum
659
+ sum_ = current_sum + self ._previous_sum
660
660
# Only update min/max on delta -> cumulative
661
- max_ = max (current_point . max , self ._previous_max )
662
- min_ = min (current_point . min , self ._previous_min )
661
+ max_ = max (current_max , self ._previous_max )
662
+ min_ = min (current_min , self ._previous_min )
663
663
664
664
self ._merge (
665
665
self ._previous_positive ,
666
- current_point . positive ,
667
- current_point . scale ,
666
+ current_positive ,
667
+ current_scale ,
668
668
min_scale ,
669
669
aggregation_temporality ,
670
670
)
671
671
self ._merge (
672
672
self ._previous_negative ,
673
- current_point . negative ,
674
- current_point . scale ,
673
+ current_negative ,
674
+ current_scale ,
675
675
min_scale ,
676
676
aggregation_temporality ,
677
677
)
678
678
679
679
else :
680
680
start_time_unix_nano = self ._previous_start_time_unix_nano
681
- sum_ = current_point . sum - self ._previous_sum
682
- max_ = current_point . max
683
- min_ = current_point . min
681
+ sum_ = current_sum - self ._previous_sum
682
+ max_ = current_max
683
+ min_ = current_min
684
684
685
685
self ._merge (
686
686
self ._previous_positive ,
687
- current_point . positive ,
688
- current_point . scale ,
687
+ current_positive ,
688
+ current_scale ,
689
689
min_scale ,
690
690
aggregation_temporality ,
691
691
)
692
692
self ._merge (
693
693
self ._previous_negative ,
694
- current_point . negative ,
695
- current_point . scale ,
694
+ current_negative ,
695
+ current_scale ,
696
696
min_scale ,
697
697
aggregation_temporality ,
698
698
)
699
699
700
700
current_point = ExponentialHistogramDataPoint (
701
701
attributes = self ._attributes ,
702
702
start_time_unix_nano = start_time_unix_nano ,
703
- time_unix_nano = current_point . time_unix_nano ,
703
+ time_unix_nano = collection_start_nano ,
704
704
count = current_count ,
705
705
sum = sum_ ,
706
706
scale = current_scale ,
@@ -804,7 +804,7 @@ def _merge(
804
804
current_change = current_scale - min_scale
805
805
806
806
for current_bucket_index , current_bucket in enumerate (
807
- current_buckets .bucket_counts
807
+ current_buckets .counts
808
808
):
809
809
810
810
if current_bucket == 0 :
0 commit comments