19808 fixed publisher setup (#2579)

bcgov · Apr 11, 2024 · 364e817 · 364e817
1 parent 3af578e
commit 364e817
Show file tree

Hide file tree

Showing 9 changed files with 9 additions and 9 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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):