Skip to content

Commit e4364d2

Browse files
authored
fix: Change retry multiplier from 1.3 to 4, for requests that retry Resour… (#971)
* fix: Change retry multiplier from 1.3 to 4, for requests that retry ResourceExhausted.
1 parent 62c595a commit e4364d2

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

google/pubsub_v1/services/publisher/async_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -556,7 +556,7 @@ async def sample_publish():
556556
default_retry=retries.Retry(
557557
initial=0.1,
558558
maximum=60.0,
559-
multiplier=1.3,
559+
multiplier=4.0,
560560
predicate=retries.if_exception_type(
561561
core_exceptions.Aborted,
562562
core_exceptions.Cancelled,

google/pubsub_v1/services/publisher/transports/base.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,7 @@ def _prep_wrapped_messages(self, client_info):
162162
default_retry=retries.Retry(
163163
initial=0.1,
164164
maximum=60.0,
165-
multiplier=1.3,
165+
multiplier=4.0,
166166
predicate=retries.if_exception_type(
167167
core_exceptions.Aborted,
168168
core_exceptions.Cancelled,

google/pubsub_v1/services/subscriber/async_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1383,7 +1383,7 @@ def request_generator():
13831383
default_retry=retries.Retry(
13841384
initial=0.1,
13851385
maximum=60.0,
1386-
multiplier=1.3,
1386+
multiplier=4.0,
13871387
predicate=retries.if_exception_type(
13881388
core_exceptions.Aborted,
13891389
core_exceptions.DeadlineExceeded,

google/pubsub_v1/services/subscriber/transports/base.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -255,7 +255,7 @@ def _prep_wrapped_messages(self, client_info):
255255
default_retry=retries.Retry(
256256
initial=0.1,
257257
maximum=60.0,
258-
multiplier=1.3,
258+
multiplier=4.0,
259259
predicate=retries.if_exception_type(
260260
core_exceptions.Aborted,
261261
core_exceptions.DeadlineExceeded,

0 commit comments

Comments
 (0)