Skip to content
This repository was archived by the owner on Mar 9, 2026. It is now read-only.

Commit 8f71624

Browse files
committed
Update subscribe_opentelemetry.py
1 parent 0dd9115 commit 8f71624

1 file changed

Lines changed: 4 additions & 3 deletions

File tree

google/cloud/pubsub_v1/open_telemetry/subscribe_opentelemetry.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -168,9 +168,9 @@ def start_process_span(self) -> trace.Span:
168168
publish_create_span: trace.Span = trace.get_current_span(
169169
self._publisher_create_span_context
170170
)
171-
span_context: Optional[
172-
trace.SpanContext
173-
] = publish_create_span.get_span_context()
171+
span_context: Optional[trace.SpanContext] = (
172+
publish_create_span.get_span_context()
173+
)
174174
publish_create_span_link = (
175175
trace.Link(span_context) if span_context else None
176176
)
@@ -208,6 +208,7 @@ def __exit__(self, exc_type, exc_val, traceback):
208208
if self._process_span:
209209
self.end_process_span()
210210

211+
211212
def start_modack_span(
212213
subscribe_span_links: List[trace.Link],
213214
subscription_id: Optional[str],

0 commit comments

Comments
 (0)