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

Commit 941d2e1

Browse files
committed
fix for ot setter
1 parent b08cd67 commit 941d2e1

File tree

1 file changed

+17
-15
lines changed

1 file changed

+17
-15
lines changed

google/cloud/spanner_v1/_helpers.py

Lines changed: 17 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -55,25 +55,27 @@
5555
)
5656

5757

58-
class OpenTelemetryContextSetter(Setter):
59-
"""
60-
Used by Open Telemetry for context propagation.
61-
"""
58+
if HAS_OPENTELEMETRY_INSTALLED:
6259

63-
def set(self, carrier: List[Tuple[str, str]], key: str, value: str) -> None:
60+
class OpenTelemetryContextSetter(Setter):
61+
"""
62+
Used by Open Telemetry for context propagation.
6463
"""
65-
Injects trace context into Spanner metadata
6664

67-
Args:
68-
carrier(PubsubMessage): The Pub/Sub message which is the carrier of Open Telemetry
69-
data.
70-
key(str): The key for which the Open Telemetry context data needs to be set.
71-
value(str): The Open Telemetry context value to be set.
65+
def set(self, carrier: List[Tuple[str, str]], key: str, value: str) -> None:
66+
"""
67+
Injects trace context into Spanner metadata
7268
73-
Returns:
74-
None
75-
"""
76-
carrier.append((key, value))
69+
Args:
70+
carrier(PubsubMessage): The Pub/Sub message which is the carrier of Open Telemetry
71+
data.
72+
key(str): The key for which the Open Telemetry context data needs to be set.
73+
value(str): The Open Telemetry context value to be set.
74+
75+
Returns:
76+
None
77+
"""
78+
carrier.append((key, value))
7779

7880

7981
def _try_to_coerce_bytes(bytestring):

0 commit comments

Comments
 (0)