Commite4364d2

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 parent62c595a commite4364d2Copy full SHA for e4364d2

File tree

-4

lines changed

-4

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -556,7 +556,7 @@ async def sample_publish():`
`556`	`556`	`default_retry=retries.Retry(`
`557`	`557`	`initial=0.1,`
`558`	`558`	`maximum=60.0,`
`559`		`-multiplier=1.3,`
	`559`	`+multiplier=4.0,`
`560`	`560`	`predicate=retries.if_exception_type(`
`561`	`561`	`core_exceptions.Aborted,`
`562`	`562`	`core_exceptions.Cancelled,`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -162,7 +162,7 @@ def _prep_wrapped_messages(self, client_info):`
`162`	`162`	`default_retry=retries.Retry(`
`163`	`163`	`initial=0.1,`
`164`	`164`	`maximum=60.0,`
`165`		`-multiplier=1.3,`
	`165`	`+multiplier=4.0,`
`166`	`166`	`predicate=retries.if_exception_type(`
`167`	`167`	`core_exceptions.Aborted,`
`168`	`168`	`core_exceptions.Cancelled,`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1383,7 +1383,7 @@ def request_generator():`
`1383`	`1383`	`default_retry=retries.Retry(`
`1384`	`1384`	`initial=0.1,`
`1385`	`1385`	`maximum=60.0,`
`1386`		`-multiplier=1.3,`
	`1386`	`+multiplier=4.0,`
`1387`	`1387`	`predicate=retries.if_exception_type(`
`1388`	`1388`	`core_exceptions.Aborted,`
`1389`	`1389`	`core_exceptions.DeadlineExceeded,`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -255,7 +255,7 @@ def _prep_wrapped_messages(self, client_info):`
`255`	`255`	`default_retry=retries.Retry(`
`256`	`256`	`initial=0.1,`
`257`	`257`	`maximum=60.0,`
`258`		`-multiplier=1.3,`
	`258`	`+multiplier=4.0,`
`259`	`259`	`predicate=retries.if_exception_type(`
`260`	`260`	`core_exceptions.Aborted,`
`261`	`261`	`core_exceptions.DeadlineExceeded,`

Comments

(0)