@@ -76,7 +76,7 @@ def _extract_metrics_header(metadata):
7676 # Key located. Check the rest of the list for duplicate entries
7777 arbitrary_metadata = list (metadata [:i ])
7878 metric_values = [val ]
79- for k , v in metadata [i + 1 :]:
79+ for k , v in metadata [i + 1 :]:
8080 if k == client_info .METRICS_METADATA_KEY :
8181 metric_values .append (v )
8282 else :
@@ -85,6 +85,7 @@ def _extract_metrics_header(metadata):
8585 # No key found
8686 return list (metadata ), []
8787
88+
8889class _GapicCallable (object ):
8990 """Callable that applies retry, timeout, and metadata logic.
9091
@@ -148,7 +149,9 @@ def __call__(
148149 metadata = kwargs .get ("metadata" )
149150 if not metadata :
150151 if self ._metrics_values :
151- kwargs ["metadata" ] = [(client_info .METRICS_METADATA_KEY , self ._metrics_values )] + self ._arbitrary_metadata
152+ kwargs ["metadata" ] = [
153+ (client_info .METRICS_METADATA_KEY , self ._metrics_values )
154+ ] + self ._arbitrary_metadata
152155 else :
153156 kwargs ["metadata" ] = self ._arbitrary_metadata
154157 else :
@@ -157,7 +160,9 @@ def __call__(
157160 if self ._metrics_values :
158161 api_client_values .append (self ._metrics_values )
159162 if api_client_values :
160- merged_metadata .append ((client_info .METRICS_METADATA_KEY , " " .join (api_client_values )))
163+ merged_metadata .append (
164+ (client_info .METRICS_METADATA_KEY , " " .join (api_client_values ))
165+ )
161166 merged_metadata .extend (self ._arbitrary_metadata )
162167 kwargs ["metadata" ] = merged_metadata
163168
0 commit comments