diff --git a/modules/google/testcontainers/google/pubsub.py b/modules/google/testcontainers/google/pubsub.py index 78c6929e..70603059 100644 --- a/modules/google/testcontainers/google/pubsub.py +++ b/modules/google/testcontainers/google/pubsub.py @@ -56,7 +56,15 @@ def _get_client(self, cls: type, **kwargs) -> dict: return cls(**kwargs) def get_publisher_client(self, **kwargs) -> pubsub.PublisherClient: + from google.auth import credentials + + kwargs["client_options"] = {"api_endpoint": self.get_pubsub_emulator_host()} + kwargs["credentials"] = credentials.AnonymousCredentials() return self._get_client(pubsub.PublisherClient, **kwargs) def get_subscriber_client(self, **kwargs) -> pubsub.SubscriberClient: + from google.auth import credentials + + kwargs["client_options"] = {"api_endpoint": self.get_pubsub_emulator_host()} + kwargs["credentials"] = credentials.AnonymousCredentials() return self._get_client(pubsub.SubscriberClient, **kwargs)