From c497764ae62ec16c8b5c82e50f790508b91c121a Mon Sep 17 00:00:00 2001 From: Anuraag Agrawal Date: Fri, 23 Jan 2026 13:46:10 +0900 Subject: [PATCH] asyncio: use test_base helpers to get metrics --- .../tests/test_asyncio_future_cancellation.py | 13 ++++--------- 1 file changed, 4 insertions(+), 9 deletions(-) diff --git a/instrumentation/opentelemetry-instrumentation-asyncio/tests/test_asyncio_future_cancellation.py b/instrumentation/opentelemetry-instrumentation-asyncio/tests/test_asyncio_future_cancellation.py index f8f4e5f230..99a3991e38 100644 --- a/instrumentation/opentelemetry-instrumentation-asyncio/tests/test_asyncio_future_cancellation.py +++ b/instrumentation/opentelemetry-instrumentation-asyncio/tests/test_asyncio_future_cancellation.py @@ -36,25 +36,20 @@ async def future_cancelled(): asyncio.run(future_cancelled()) except asyncio.CancelledError as exc: self.assertEqual(isinstance(exc, asyncio.CancelledError), True) - spans = self.memory_exporter.get_finished_spans() + spans = self.get_finished_spans() self.assertEqual(len(spans), 2) self.assertEqual(spans[0].name, "root") self.assertEqual(spans[1].name, "asyncio future") - metrics = ( - self.memory_metrics_reader.get_metrics_data() - .resource_metrics[0] - .scope_metrics[0] - .metrics - ) + metrics = self.get_sorted_metrics() self.assertEqual(len(metrics), 2) - self.assertEqual(metrics[0].name, "asyncio.process.duration") + self.assertEqual(metrics[0].name, "asyncio.process.created") self.assertEqual( metrics[0].data.data_points[0].attributes["state"], "cancelled" ) - self.assertEqual(metrics[1].name, "asyncio.process.created") + self.assertEqual(metrics[1].name, "asyncio.process.duration") self.assertEqual( metrics[1].data.data_points[0].attributes["state"], "cancelled" )