Skip to content

Commit 51ce289

Browse files
committed
Address linting issues
1 parent dda47a1 commit 51ce289

File tree

2 files changed

+11
-6
lines changed

2 files changed

+11
-6
lines changed

instrumentation/opentelemetry-instrumentation-grpc/src/opentelemetry/instrumentation/grpc/_aio_server.py

+1
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
from opentelemetry.semconv.trace import SpanAttributes
2525
from opentelemetry.trace.status import Status, StatusCode
2626

27+
2728
class _OpenTelemetryAioServicerContext(wrapt.ObjectProxy):
2829
def __init__(self, servicer_context, active_span):
2930
super().__init__(servicer_context)

instrumentation/opentelemetry-instrumentation-grpc/tests/test_aio_server_interceptor.py

+10-6
Original file line numberDiff line numberDiff line change
@@ -520,7 +520,9 @@ async def request(channel):
520520
with testcase.assertRaises(grpc.RpcError) as cm:
521521
await channel.unary_unary(rpc_call)(msg)
522522

523-
self.assertEqual(cm.exception.code(), grpc.StatusCode.FAILED_PRECONDITION)
523+
self.assertEqual(
524+
cm.exception.code(), grpc.StatusCode.FAILED_PRECONDITION
525+
)
524526
self.assertEqual(cm.exception.details(), failure_message)
525527

526528
await run_with_test_server(request, servicer=AbortServicer())
@@ -567,11 +569,11 @@ async def test_abort_with_trailing_metadata(self):
567569
class AbortServicer(GRPCTestServerServicer):
568570
# pylint:disable=C0103
569571
async def SimpleMethod(self, request, context):
570-
metadata = (
571-
("meta", "data"),
572-
)
572+
metadata = (("meta", "data"),)
573573
await context.abort(
574-
grpc.StatusCode.FAILED_PRECONDITION, failure_message, trailing_metadata=metadata
574+
grpc.StatusCode.FAILED_PRECONDITION,
575+
failure_message,
576+
trailing_metadata=metadata,
575577
)
576578

577579
testcase = self
@@ -583,7 +585,9 @@ async def request(channel):
583585
with testcase.assertRaises(grpc.RpcError) as cm:
584586
await channel.unary_unary(rpc_call)(msg)
585587

586-
self.assertEqual(cm.exception.code(), grpc.StatusCode.FAILED_PRECONDITION)
588+
self.assertEqual(
589+
cm.exception.code(), grpc.StatusCode.FAILED_PRECONDITION
590+
)
587591
self.assertEqual(cm.exception.details(), failure_message)
588592

589593
await run_with_test_server(request, servicer=AbortServicer())

0 commit comments

Comments
 (0)