fix: set creds only if transport not provided

Author: ohmayr

google/cloud/pubsub_v1/publisher/client.py

@@ -132,7 +132,9 @@ def __init__(
  kwargs["client_options"] = {
  "api_endpoint": os.environ.get("PUBSUB_EMULATOR_HOST")
  }
- kwargs["credentials"] = AnonymousCredentials()
+ # Configure credentials directly to transport, if provided.
+ if not kwargs["transport"]:
+ kwargs["credentials"] = AnonymousCredentials()
 
  # For a transient failure, retry publishing the message infinitely.
  self.publisher_options = types.PublisherOptions(*publisher_options)

google/cloud/pubsub_v1/subscriber/client.py

@@ -85,7 +85,9 @@ def __init__(
  kwargs["client_options"] = {
  "api_endpoint": os.environ.get("PUBSUB_EMULATOR_HOST")
  }
- kwargs["credentials"] = AnonymousCredentials()
+ # Configure credentials directly to transport, if provided.
+ if not kwargs["transport"]:
+ kwargs["credentials"] = AnonymousCredentials()
 
  # Instantiate the underlying GAPIC client.
  super().__init__(**kwargs)