@@ -52,6 +52,7 @@ class {{ service.name }}RestTransport({{ service.name }}Transport):
52
52
client_cert_source_for_mtls: Callable[[], Tuple[bytes, bytes]] = None,
53
53
quota_project_id: Optional[str] = None,
54
54
client_info: gapic_v1.client_info.ClientInfo = DEFAULT_CLIENT_INFO,
55
+ always_use_jwt_access: Optional[bool] = False,
55
56
) -> None:
56
57
"""Instantiate the transport.
57
58
@@ -88,6 +89,7 @@ class {{ service.name }}RestTransport({{ service.name }}Transport):
88
89
host=host,
89
90
credentials=credentials,
90
91
client_info=client_info,
92
+ always_use_jwt_access=always_use_jwt_access,
91
93
)
92
94
self._session = AuthorizedSession(self._credentials, default_host=self.DEFAULT_HOST)
93
95
{% if service .has_lro %}
@@ -196,23 +198,17 @@ class {{ service.name }}RestTransport({{ service.name }}Transport):
196
198
if {{ method.input.ident }}.{{ field }} in request:
197
199
query_params['{{ field|camel_case }}'] = request.{{ field }}
198
200
{% else %}
199
- if request.{{ field }}:
200
- query_params['{{ field|camel_case }}'] = request.{{ field }}
201
+ query_params['{{ field|camel_case }}'] = request.{{ field }}
201
202
{% endif %}
202
203
{% endfor %}
203
204
204
- # TODO(yon-mg): further discussion needed whether 'python truthiness' is appropriate here
205
- # discards default values
206
- # TODO(yon-mg): add test for proper url encoded strings
207
- query_params = ['{k}={v}'.format(k=k, v=v) for k, v in query_params.items()]
208
- url += '?{}'.format('& '.join(query_params)).replace(' ', '+')
209
-
210
205
# Send the request
211
206
headers = dict(metadata)
212
207
headers['Content-Type'] = 'application/json'
213
208
response = self._session.{{ method.http_opt['verb'] }}(
214
209
url,
215
210
headers=headers,
211
+ params=query_params,
216
212
{% if 'body' in method .http_opt %}
217
213
data=body,
218
214
{% endif %}
0 commit comments