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

Commit 3e0d134

Browse files
committed
improved comments
1 parent 5390813 commit 3e0d134

2 files changed

Lines changed: 3 additions & 2 deletions

File tree

google/cloud/bigtable/data/_async/metrics_interceptor.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,6 +134,7 @@ async def intercept_unary_stream(
134134
operation, await continuation(client_call_details, request)
135135
)
136136
except Exception as rpc_error:
137+
# handle errors while intializing stream
137138
metadata = await _get_metadata(rpc_error)
138139
if metadata is not None:
139140
operation.add_response_metadata(metadata)
@@ -143,7 +144,7 @@ async def intercept_unary_stream(
143144
@CrossSync.convert
144145
async def _streaming_generator_wrapper(operation, call):
145146
"""
146-
Wrapped generator to be returned by intercept_unary_stream
147+
Wrapped generator to be returned by intercept_unary_stream.
147148
"""
148149
# only track has_first response for READ_ROWS
149150
has_first_response = (

google/cloud/bigtable/data/_sync_autogen/metrics_interceptor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ def intercept_unary_stream(
102102

103103
@staticmethod
104104
def _streaming_generator_wrapper(operation, call):
105-
"""Wrapped generator to be returned by intercept_unary_stream"""
105+
"""Wrapped generator to be returned by intercept_unary_stream."""
106106
has_first_response = (
107107
operation.first_response_latency_ns is not None
108108
or operation.op_type != OperationType.READ_ROWS

0 commit comments

Comments
 (0)