fix: pass anonymous credentials for emulator (#250)

googleapis · Dec 21, 2020 · 8eed8e1 · 8eed8e1
1 parent 2584147
commit 8eed8e1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/google/cloud/pubsub_v1/publisher/client.py b/google/cloud/pubsub_v1/publisher/client.py
@@ -26,6 +26,7 @@
 
 from google.api_core import gapic_v1
 from google.api_core import grpc_helpers
+from google.auth.credentials import AnonymousCredentials
 from google.oauth2 import service_account
 
 from google.cloud.pubsub_v1 import _gapic
@@ -129,6 +130,7 @@ def __init__(self, batch_settings=(), publisher_options=(), **kwargs):
             kwargs["channel"] = grpc.insecure_channel(
                 target=os.environ.get("PUBSUB_EMULATOR_HOST")
             )
+            kwargs["credentials"] = AnonymousCredentials()
 
         # The GAPIC client has mTLS logic to determine the api endpoint and the
         # ssl credentials to use. Here we create a GAPIC client to help compute the

diff --git a/google/cloud/pubsub_v1/subscriber/client.py b/google/cloud/pubsub_v1/subscriber/client.py
@@ -20,6 +20,7 @@
 import grpc
 
 from google.api_core import grpc_helpers
+from google.auth.credentials import AnonymousCredentials
 from google.oauth2 import service_account
 
 from google.cloud.pubsub_v1 import _gapic
@@ -80,6 +81,7 @@ def __init__(self, **kwargs):
             kwargs["channel"] = grpc.insecure_channel(
                 target=os.environ.get("PUBSUB_EMULATOR_HOST")
             )
+            kwargs["credentials"] = AnonymousCredentials()
 
         # The GAPIC client has mTLS logic to determine the api endpoint and the
         # ssl credentials to use. Here we create a GAPIC client to help compute the