@@ -58,72 +58,3 @@ def test_export(self):
5858 for export_status in self .span_processor .export_status :
5959 self .assertEqual (export_status .name , "SUCCESS" )
6060 self .assertEqual (export_status .value , 0 )
61-
62-
63- # FIXME This test fails because of an issue in the OpenCensus collector
64- # reported here:
65- # https://github.com/census-instrumentation/opencensus-service/issues/641
66- # Uncomment this test when this issue gets fixed.
67-
68- # from time import sleep
69- # from opentelemetry.ext.opencensusexporter.metrics_exporter import (
70- # OpenCensusMetricsExporter,
71- # )
72- # from opentelemetry.sdk.metrics import Counter, MeterProvider
73- # from opentelemetry.sdk.metrics.export.controller import PushController
74-
75- # from opentelemetry import metrics
76- #
77- #
78- # class ExportStatusMetricController(PushController):
79- # def __init__(self, *args, **kwargs):
80- # super().__init__(*args, **kwargs)
81- # self.export_status = []
82- #
83- # def run(self):
84- # while not self.finished.wait(self.interval):
85- # self.tick()
86- #
87- # def tick(self):
88- # # Collect all of the meter's metrics to be exported
89- # self.meter.collect()
90- # token = attach(set_value("suppress_instrumentation", True))
91- # # Export the given metrics in the batcher
92- # self.export_status.append(
93- # self.exporter.export(self.meter.batcher.checkpoint_set())
94- # )
95- # detach(token)
96- # # Perform post-exporting logic based on batcher configuration
97- # self.meter.batcher.finished_collection()
98- #
99- #
100- # class TestOpenCensusMetricsExporter(TestBase):
101- # def setUp(self):
102- # super().setUp()
103- #
104- # metrics.set_meter_provider(MeterProvider())
105- # self.meter = metrics.get_meter(__name__)
106- # self.controller = ExportStatusMetricController(
107- # self.meter,
108- # OpenCensusMetricsExporter(
109- # service_name="basic-service", endpoint="localhost:55678"
110- # ),
111- # 1,
112- # )
113- #
114- # def test_export(self):
115- #
116- # self.meter.create_metric(
117- # name="requests",
118- # description="number of requests",
119- # unit="1",
120- # value_type=int,
121- # metric_type=Counter,
122- # label_keys=("environment",),
123- # ).add(25, {"environment": "staging"})
124- #
125- # sleep(2)
126- #
127- # self.assertEqual(len(self.controller.export_status), 1)
128- # self.assertEqual(self.controller.export_status[0].name, "SUCCESS")
129- # self.assertEqual(self.controller.export_status[0].value, 0)
0 commit comments