From cc4978f9f6bc8dd99ed83bdc58dcadd1628110d6 Mon Sep 17 00:00:00 2001 From: Peter Lamut Date: Tue, 29 Oct 2019 13:13:34 +0200 Subject: [PATCH] (DELETE) Make subscription permission test fail --- .../pubsub_v1/subscriber/_protocol/streaming_pull_manager.py | 1 + 1 file changed, 1 insertion(+) 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 index d3b1d6f51eb6f..3e78074e4f74a 100644 --- 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