Commitfc9da22

authored

Updated retry timeout (#497)

* Updated the retry_logic* Added logging for checking retry time

1 parent4c62c69 commitfc9da22Copy full SHA for fc9da22

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -290,8 +290,9 @@ def sleep_for_retry(self, response: BaseHTTPResponse) -> bool:`
`290`	`290`	`else:`
`291`	`291`	`proposed_wait=self.get_backoff_time()`
`292`	`292`
`293`		`-proposed_wait=min(proposed_wait,self.delay_max)`
	`293`	`+proposed_wait=max(proposed_wait,self.delay_max)`
`294`	`294`	`self.check_proposed_wait(proposed_wait)`
	`295`	`+logger.debug(f"Retrying after{proposed_wait} seconds")`
`295`	`296`	`time.sleep(proposed_wait)`
`296`	`297`	`returnTrue`
`297`	`298`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -66,7 +66,7 @@`
`66`	`66`	`# - 900s attempts-duration lines up w ODBC/JDBC drivers (for cluster startup > 10 mins)`
`67`	`67`	`_retry_policy= {# (type, default, min, max)`
`68`	`68`	`"_retry_delay_min": (float,1,0.1,60),`
`69`		`-"_retry_delay_max": (float,30,5,3600),`
	`69`	`+"_retry_delay_max": (float,60,5,3600),`
`70`	`70`	`"_retry_stop_after_attempts_count": (int,30,1,60),`
`71`	`71`	`"_retry_stop_after_attempts_duration": (float,900,1,86400),`
`72`	`72`	`"_retry_delay_default": (float,5,1,60),`

Comments

(0)