Skip to content

Commit 4165741

Browse files
Add split_resource_metrics
1 parent 6b91fcb commit 4165741

File tree

1 file changed

+4
-4
lines changed
  • exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/metric_exporter

1 file changed

+4
-4
lines changed

exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/metric_exporter/__init__.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -305,7 +305,7 @@ def _split_metrics_data(
305305
metrics_data: metrics object based on HTTP protocol buffer definition
306306
"""
307307
batch_size: int = 0
308-
# TODO: Account for multiple ResourceMetrics in original MetricsData
308+
split_resource_metrics: List[pb2.ResourceMetrics] = []
309309

310310
for resource_metrics in metrics_data.resource_metrics:
311311
new_resource_metrics = pb2.ResourceMetrics(
@@ -512,11 +512,11 @@ def _split_metrics_data(
512512
if new_scope_metrics.metrics:
513513
new_resource_metrics.scope_metrics.append(new_scope_metrics)
514514

515-
# TODO: Account for multiple ResourceMetrics in original MetricsData
515+
if new_resource_metrics.scope_metrics:
516+
split_resource_metrics.append(new_resource_metrics)
516517

517518
if batch_size > 0:
518-
# TODO: Account for multiple ResourceMetrics in original MetricsData
519-
yield pb2.MetricsData(resource_metrics=[new_resource_metrics])
519+
yield pb2.MetricsData(resource_metrics=split_resource_metrics)
520520

521521
def shutdown(self, timeout_millis: float = 30_000, **kwargs) -> None:
522522
pass

0 commit comments

Comments
 (0)