From b0c35034115a9d982e9870cca25c147eeef93a32 Mon Sep 17 00:00:00 2001 From: Peter Lamut Date: Tue, 11 Jun 2019 17:40:35 +0200 Subject: [PATCH] Enable Bidi reopen throttling in SPM --- .../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 159bdfd8d9e57..68ab452fc5640 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 @@ -383,6 +383,7 @@ def open(self, callback, on_callback_error): start_rpc=self._client.api.streaming_pull, initial_request=self._get_initial_request, should_recover=self._should_recover, + throttle_reopen=True, ) self._rpc.add_done_callback(self._on_rpc_done)