fix: Test failures due to grpcio changes

mukund-ananthu · mukund-ananthu · commit bb1ed8d4f887 · 2024-05-29T19:33:57.000Z
* Failures can be found in googleapis/python-api-common-protos#223
diff --git a/tests/unit/pubsub_v1/publisher/test_publisher_client.py b/tests/unit/pubsub_v1/publisher/test_publisher_client.py
@@ -135,15 +135,15 @@ def test_init_w_api_endpoint(creds):
 
     assert (client._transport.grpc_channel._channel.target()).decode(
         "utf-8"
-    ) == "testendpoint.google.com:443"
+    ) == "dns:///testendpoint.google.com:443" if grpc.__version__ >= "1.63.0" else "testendpoint.google.com:443"
 
 
 def test_init_w_empty_client_options(creds):
     client = publisher.Client(client_options={}, credentials=creds)
 
     assert (client._transport.grpc_channel._channel.target()).decode(
         "utf-8"
-    ) == publisher_client.PublisherClient.SERVICE_ADDRESS
+    ) == ()"dns:///pubsub.googleapis.com:443"
 
 
 def test_init_client_options_pass_through():
@@ -182,7 +182,7 @@ def test_init_emulator(monkeypatch):
     # Sadly, there seems to be no good way to do this without poking at
     # the private API of gRPC.
     channel = client._transport.publish._channel
-    assert channel.target().decode("utf8") == "/foo/bar:123"
+    assert channel.target().decode("utf8") == "dns:////foo/bar:123"
 
 
 def test_message_ordering_enabled(creds):
diff --git a/tests/unit/pubsub_v1/subscriber/test_subscriber_client.py b/tests/unit/pubsub_v1/subscriber/test_subscriber_client.py
@@ -68,15 +68,15 @@ def test_init_w_api_endpoint(creds):
 
     assert (client._transport.grpc_channel._channel.target()).decode(
         "utf-8"
-    ) == "testendpoint.google.com:443"
+    ) == "dns:///testendpoint.google.com:443"
 
 
 def test_init_w_empty_client_options(creds):
     client = subscriber.Client(client_options={}, credentials=creds)
 
     assert (client._transport.grpc_channel._channel.target()).decode(
         "utf-8"
-    ) == subscriber_client.SubscriberClient.SERVICE_ADDRESS
+    ) == "dns:///pubsub.googleapis.com:443"
 
 
 def test_init_client_options_pass_through():
@@ -115,7 +115,7 @@ def test_init_emulator(monkeypatch):
     # Sadly, there seems to be no good way to do this without poking at
     # the private API of gRPC.
     channel = client._transport.pull._channel
-    assert channel.target().decode("utf8") == "/baz/bacon:123"
+    assert channel.target().decode("utf8") == "dns:////baz/bacon:123"
 
 
 def test_class_method_factory():
