Skip to content

Commit d1f5f43

Browse files
committed
Fix lint
1 parent f579964 commit d1f5f43

File tree

2 files changed

+17
-11
lines changed

2 files changed

+17
-11
lines changed

instrumentation/opentelemetry-instrumentation-tornado/src/opentelemetry/instrumentation/tornado/__init__.py

+7-1
Original file line numberDiff line numberDiff line change
@@ -366,6 +366,8 @@ def _log_exception(instrumentation, func, handler, args, kwargs):
366366
if len(args) == 3:
367367
error = args[1]
368368

369+
_record_on_finish_metrics(instrumentation, handler, error)
370+
369371
_finish_span(instrumentation, handler, error)
370372
return func(*args, **kwargs)
371373

@@ -535,11 +537,15 @@ def _record_prepare_metrics(instrumentation, handler):
535537
)
536538

537539

538-
def _record_on_finish_metrics(instrumentation, handler):
540+
def _record_on_finish_metrics(instrumentation, handler, error=None):
539541
elapsed_time = round((default_timer() - instrumentation.start_time) * 1000)
540542

541543
response_size = int(handler._headers.get("Content-Length", 0))
542544
metric_attributes = _create_metric_attributes(handler)
545+
546+
if isinstance(error, tornado.web.HTTPError):
547+
metric_attributes[SpanAttributes.HTTP_STATUS_CODE] = error.status_code
548+
543549
instrumentation.response_size_histogram.record(
544550
response_size, attributes=metric_attributes
545551
)

instrumentation/opentelemetry-instrumentation-tornado/tests/test_metrics_instrumentation.py

+10-10
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ def get_sorted_metrics(self):
4141
)
4242
for metrics in resource_metrics:
4343
for scope_metrics in metrics.scope_metrics:
44-
all_metrics = [metric for metric in scope_metrics.metrics]
44+
all_metrics = list(scope_metrics.metrics)
4545
return self.sorted_metrics(all_metrics)
4646

4747
@staticmethod
@@ -54,7 +54,7 @@ def sorted_metrics(metrics):
5454
key=lambda m: m.name,
5555
)
5656

57-
def assertMetricExpected(
57+
def assert_metric_expected(
5858
self, metric, expected_value, expected_attributes
5959
):
6060
data_point = next(metric.data.data_points)
@@ -75,7 +75,7 @@ def assertMetricExpected(
7575
dict(data_point.attributes),
7676
)
7777

78-
def assertDurationMetricExpected(
78+
def assert_duration_metric_expected(
7979
self, metric, duration_estimated, expected_attributes
8080
):
8181
data_point = next(metric.data.data_points)
@@ -130,7 +130,7 @@ def test_basic_metrics(self):
130130
self.assertEqual(
131131
server_active_request.name, "http.server.active_requests"
132132
)
133-
self.assertMetricExpected(
133+
self.assert_metric_expected(
134134
server_active_request,
135135
0,
136136
{
@@ -143,7 +143,7 @@ def test_basic_metrics(self):
143143
)
144144

145145
self.assertEqual(server_duration.name, "http.server.duration")
146-
self.assertDurationMetricExpected(
146+
self.assert_duration_metric_expected(
147147
server_duration,
148148
client_duration_estimated,
149149
{
@@ -157,7 +157,7 @@ def test_basic_metrics(self):
157157
)
158158

159159
self.assertEqual(server_request_size.name, "http.server.request.size")
160-
self.assertMetricExpected(
160+
self.assert_metric_expected(
161161
server_request_size,
162162
0,
163163
{
@@ -173,7 +173,7 @@ def test_basic_metrics(self):
173173
self.assertEqual(
174174
server_response_size.name, "http.server.response.size"
175175
)
176-
self.assertMetricExpected(
176+
self.assert_metric_expected(
177177
server_response_size,
178178
len(response.body),
179179
{
@@ -187,7 +187,7 @@ def test_basic_metrics(self):
187187
)
188188

189189
self.assertEqual(client_duration.name, "http.client.duration")
190-
self.assertDurationMetricExpected(
190+
self.assert_duration_metric_expected(
191191
client_duration,
192192
client_duration_estimated,
193193
{
@@ -198,7 +198,7 @@ def test_basic_metrics(self):
198198
)
199199

200200
self.assertEqual(client_request_size.name, "http.client.request.size")
201-
self.assertMetricExpected(
201+
self.assert_metric_expected(
202202
client_request_size,
203203
0,
204204
{
@@ -211,7 +211,7 @@ def test_basic_metrics(self):
211211
self.assertEqual(
212212
client_response_size.name, "http.client.response.size"
213213
)
214-
self.assertMetricExpected(
214+
self.assert_metric_expected(
215215
client_response_size,
216216
len(response.body),
217217
{

0 commit comments

Comments
 (0)