From 34fc0aa42b77afe052c58ff9faf9f2971f05d7fa Mon Sep 17 00:00:00 2001 From: Karim El Jazzar <122301442+JazzarKarim@users.noreply.github.com> Date: Thu, 11 Apr 2024 11:29:13 -0700 Subject: [PATCH] 19808 fixed publisher setup (#2579) --- jobs/email-reminder/services/gcp_queue.py | 2 +- jobs/future-effective-filings/services/gcp_queue.py | 2 +- jobs/update-legal-filings/services/gcp_queue.py | 2 +- python/common/gcp-queue/gcp_queue/gcp_queue.py | 2 +- .../entity-auth/src/entity_auth/services/gcp_queue.py | 2 +- queue_services/entity-bn/src/entity_bn/services/gcp_queue.py | 2 +- .../entity-emailer/src/entity_emailer/services/gcp_queue.py | 2 +- .../entity-filer/src/entity_filer/services/gcp_queue.py | 2 +- queue_services/entity-pay/src/entity_pay/services/gcp_queue.py | 2 +- 9 files changed, 9 insertions(+), 9 deletions(-) diff --git a/jobs/email-reminder/services/gcp_queue.py b/jobs/email-reminder/services/gcp_queue.py index a822eb9ecf..0b1c554818 100644 --- a/jobs/email-reminder/services/gcp_queue.py +++ b/jobs/email-reminder/services/gcp_queue.py @@ -96,7 +96,7 @@ def publisher(self): self._publisher = pubsub_v1.PublisherClient(credentials=self.credentials_pub) else: self._publisher = pubsub_v1.PublisherClient() - return self.credentials_pub + return self._publisher @staticmethod def is_valid_envelope(msg: dict): diff --git a/jobs/future-effective-filings/services/gcp_queue.py b/jobs/future-effective-filings/services/gcp_queue.py index b5a2f6499d..74383827d4 100644 --- a/jobs/future-effective-filings/services/gcp_queue.py +++ b/jobs/future-effective-filings/services/gcp_queue.py @@ -95,7 +95,7 @@ def publisher(self): self._publisher = pubsub_v1.PublisherClient(credentials=self.credentials_pub) else: self._publisher = pubsub_v1.PublisherClient() - return self.credentials_pub + return self._publisher @staticmethod def is_valid_envelope(msg: dict): diff --git a/jobs/update-legal-filings/services/gcp_queue.py b/jobs/update-legal-filings/services/gcp_queue.py index 62b6f25d8c..7e66c158ae 100644 --- a/jobs/update-legal-filings/services/gcp_queue.py +++ b/jobs/update-legal-filings/services/gcp_queue.py @@ -95,7 +95,7 @@ def publisher(self): self._publisher = pubsub_v1.PublisherClient(credentials=self.credentials_pub) else: self._publisher = pubsub_v1.PublisherClient() - return self.credentials_pub + return self._publisher @staticmethod def is_valid_envelope(msg: dict): diff --git a/python/common/gcp-queue/gcp_queue/gcp_queue.py b/python/common/gcp-queue/gcp_queue/gcp_queue.py index 3204084a7a..6dcac9ee64 100644 --- a/python/common/gcp-queue/gcp_queue/gcp_queue.py +++ b/python/common/gcp-queue/gcp_queue/gcp_queue.py @@ -108,7 +108,7 @@ def publisher(self): ) else: self._publisher = pubsub_v1.PublisherClient() - return self.credentials_pub + return self._publisher @staticmethod def is_valid_envelope(msg: dict): diff --git a/queue_services/entity-auth/src/entity_auth/services/gcp_queue.py b/queue_services/entity-auth/src/entity_auth/services/gcp_queue.py index 258c707ea1..2db110859d 100644 --- a/queue_services/entity-auth/src/entity_auth/services/gcp_queue.py +++ b/queue_services/entity-auth/src/entity_auth/services/gcp_queue.py @@ -96,7 +96,7 @@ def publisher(self): self._publisher = pubsub_v1.PublisherClient(credentials=self.credentials_pub) else: self._publisher = pubsub_v1.PublisherClient() - return self.credentials_pub + return self._publisher @staticmethod def is_valid_envelope(msg: dict): diff --git a/queue_services/entity-bn/src/entity_bn/services/gcp_queue.py b/queue_services/entity-bn/src/entity_bn/services/gcp_queue.py index 258c707ea1..2db110859d 100644 --- a/queue_services/entity-bn/src/entity_bn/services/gcp_queue.py +++ b/queue_services/entity-bn/src/entity_bn/services/gcp_queue.py @@ -96,7 +96,7 @@ def publisher(self): self._publisher = pubsub_v1.PublisherClient(credentials=self.credentials_pub) else: self._publisher = pubsub_v1.PublisherClient() - return self.credentials_pub + return self._publisher @staticmethod def is_valid_envelope(msg: dict): diff --git a/queue_services/entity-emailer/src/entity_emailer/services/gcp_queue.py b/queue_services/entity-emailer/src/entity_emailer/services/gcp_queue.py index 806f144624..6438c19acd 100644 --- a/queue_services/entity-emailer/src/entity_emailer/services/gcp_queue.py +++ b/queue_services/entity-emailer/src/entity_emailer/services/gcp_queue.py @@ -96,7 +96,7 @@ def publisher(self): self._publisher = pubsub_v1.PublisherClient(credentials=self.credentials_pub) else: self._publisher = pubsub_v1.PublisherClient() - return self.credentials_pub + return self._publisher @staticmethod def is_valid_envelope(msg: dict): diff --git a/queue_services/entity-filer/src/entity_filer/services/gcp_queue.py b/queue_services/entity-filer/src/entity_filer/services/gcp_queue.py index 9d580c2427..d395917806 100644 --- a/queue_services/entity-filer/src/entity_filer/services/gcp_queue.py +++ b/queue_services/entity-filer/src/entity_filer/services/gcp_queue.py @@ -91,7 +91,7 @@ def publisher(self): self._publisher = pubsub_v1.PublisherClient(credentials=self.credentials_pub) else: self._publisher = pubsub_v1.PublisherClient() - return self.credentials_pub + return self._publisher @staticmethod def is_valid_envelope(msg: dict): diff --git a/queue_services/entity-pay/src/entity_pay/services/gcp_queue.py b/queue_services/entity-pay/src/entity_pay/services/gcp_queue.py index 7f07a71581..6af86616b8 100644 --- a/queue_services/entity-pay/src/entity_pay/services/gcp_queue.py +++ b/queue_services/entity-pay/src/entity_pay/services/gcp_queue.py @@ -99,7 +99,7 @@ def publisher(self): self._publisher = pubsub_v1.PublisherClient(credentials=self.credentials_pub) else: self._publisher = pubsub_v1.PublisherClient() - return self.credentials_pub + return self._publisher @staticmethod def is_valid_envelope(msg: dict):