(DELETE) Make subscription permission test fail

googleapis · Oct 29, 2019 · cc4978f · cc4978f
1 parent 19439b1
commit cc4978f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pubsub/google/cloud/pubsub_v1/subscriber/_protocol/streaming_pull_manager.py b/pubsub/google/cloud/pubsub_v1/subscriber/_protocol/streaming_pull_manager.py
@@ -403,6 +403,7 @@ def open(self, callback, on_callback_error):
         # the default stream ACK deadline should again be set based on the
         # historic ACK timing data, i.e. `self.ack_histogram.percentile(99)`.
         stream_ack_deadline_seconds = _DEFAULT_STREAM_ACK_DEADLINE
+        self._client.api.get_subscription(self._subscription)
 
         get_initial_request = functools.partial(
             self._get_initial_request, stream_ack_deadline_seconds