Skip to content

Commit c289c34

Browse files
fix: pass updated keyword args to Publisher/Subscriber client in google/pubsub
1 parent 8fb4bcc commit c289c34

File tree

1 file changed

+6
-0
lines changed
  • modules/google/testcontainers/google

1 file changed

+6
-0
lines changed

modules/google/testcontainers/google/pubsub.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,13 @@ def _get_client(self, cls: type, **kwargs) -> dict:
5656
return cls(**kwargs)
5757

5858
def get_publisher_client(self, **kwargs) -> pubsub.PublisherClient:
59+
from google.auth import credentials
60+
kwargs['client_options'] = dict(api_endpoint=self.get_pubsub_emulator_host())
61+
kwargs['credentials'] = credentials.AnonymousCredentials()
5962
return self._get_client(pubsub.PublisherClient, **kwargs)
6063

6164
def get_subscriber_client(self, **kwargs) -> pubsub.SubscriberClient:
65+
from google.auth import credentials
66+
kwargs['client_options'] = dict(api_endpoint=self.get_pubsub_emulator_host())
67+
kwargs['credentials'] = credentials.AnonymousCredentials()
6268
return self._get_client(pubsub.SubscriberClient, **kwargs)

0 commit comments

Comments
 (0)