This repository was archived by the owner on Nov 12, 2025. It is now read-only.
File tree Expand file tree Collapse file tree
google/cloud/bigquery_storage_v1/services/big_query_read/transports
tests/unit/gapic/bigquery_storage_v1 Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -3,3 +3,4 @@ Types for Google Cloud Bigquery Storage v1 API
33
44.. automodule :: google.cloud.bigquery_storage_v1.types
55 :members:
6+ :show-inheritance:
Original file line number Diff line number Diff line change @@ -103,13 +103,16 @@ def __init__(
103103 google.api_core.exceptions.DuplicateCredentialArgs: If both ``credentials``
104104 and ``credentials_file`` are passed.
105105 """
106+ self ._ssl_channel_credentials = ssl_channel_credentials
107+
106108 if channel :
107109 # Sanity check: Ensure that channel and credentials are not both
108110 # provided.
109111 credentials = False
110112
111113 # If a channel was explicitly provided, set it.
112114 self ._grpc_channel = channel
115+ self ._ssl_channel_credentials = None
113116 elif api_mtls_endpoint :
114117 warnings .warn (
115118 "api_mtls_endpoint and client_cert_source are deprecated" ,
@@ -150,6 +153,7 @@ def __init__(
150153 ("grpc.max_receive_message_length" , - 1 ),
151154 ),
152155 )
156+ self ._ssl_channel_credentials = ssl_credentials
153157 else :
154158 host = host if ":" in host else host + ":443"
155159
Original file line number Diff line number Diff line change @@ -148,13 +148,16 @@ def __init__(
148148 google.api_core.exceptions.DuplicateCredentialArgs: If both ``credentials``
149149 and ``credentials_file`` are passed.
150150 """
151+ self ._ssl_channel_credentials = ssl_channel_credentials
152+
151153 if channel :
152154 # Sanity check: Ensure that channel and credentials are not both
153155 # provided.
154156 credentials = False
155157
156158 # If a channel was explicitly provided, set it.
157159 self ._grpc_channel = channel
160+ self ._ssl_channel_credentials = None
158161 elif api_mtls_endpoint :
159162 warnings .warn (
160163 "api_mtls_endpoint and client_cert_source are deprecated" ,
@@ -195,6 +198,7 @@ def __init__(
195198 ("grpc.max_receive_message_length" , - 1 ),
196199 ),
197200 )
201+ self ._ssl_channel_credentials = ssl_credentials
198202 else :
199203 host = host if ":" in host else host + ":443"
200204
Original file line number Diff line number Diff line change 1+ #! /usr/bin/env python3
12# -*- coding: utf-8 -*-
23
34# Copyright 2020 Google LLC
Original file line number Diff line number Diff line change 44 "git": {
55 "name": ".",
66 "remote": "https://github.com/googleapis/python-bigquery-storage.git",
7- "sha": "fbbb439b8c77fa9367a4b5bea725dd0b0f26b769 "
7+ "sha": "8115f88db7c355c96f7cff235406e744e7b08c67 "
88 }
99 },
1010 {
1111 "git": {
1212 "name": "googleapis",
1313 "remote": "https://github.com/googleapis/googleapis.git",
14- "sha": "c7331b75b0b7bbd614373b7d37085db1c80dd4be ",
15- "internalRef": "338157137 "
14+ "sha": "07d41a7e5cade45aba6f0d277c89722b48f2c956 ",
15+ "internalRef": "339292950 "
1616 }
1717 },
1818 {
Original file line number Diff line number Diff line change @@ -1194,6 +1194,7 @@ def test_big_query_read_grpc_transport_channel():
11941194 )
11951195 assert transport .grpc_channel == channel
11961196 assert transport ._host == "squid.clam.whelk:443"
1197+ assert transport ._ssl_channel_credentials == None
11971198
11981199
11991200def test_big_query_read_grpc_asyncio_transport_channel ():
@@ -1205,6 +1206,7 @@ def test_big_query_read_grpc_asyncio_transport_channel():
12051206 )
12061207 assert transport .grpc_channel == channel
12071208 assert transport ._host == "squid.clam.whelk:443"
1209+ assert transport ._ssl_channel_credentials == None
12081210
12091211
12101212@pytest .mark .parametrize (
@@ -1255,6 +1257,7 @@ def test_big_query_read_transport_channel_mtls_with_client_cert_source(transport
12551257 ),
12561258 )
12571259 assert transport .grpc_channel == mock_grpc_channel
1260+ assert transport ._ssl_channel_credentials == mock_ssl_cred
12581261
12591262
12601263@pytest .mark .parametrize (
You can’t perform that action at this time.
0 commit comments