Commit2b68c53

committed

Also retry HTTP-based transient errors.

1 parent5a1678f commit2b68c53Copy full SHA for 2b68c53

File tree

+15

-4

lines changed

+15

-4

lines changed

Lines changed: 15 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -609,18 +609,29 @@ def http_request(`
`609`	`609`	`prepped.url, {},streamed,verify,None`
`610`	`610`	`)`
`611`	`611`
	`612`	`+retry_transient_errors=kwargs.get(`
	`613`	`+"retry_transient_errors",self.retry_transient_errors`
	`614`	`+ )`
`612`	`615`	`cur_retries=0`
`613`	`616`	`whileTrue:`
`614`		`-result=self.session.send(prepped,timeout=timeout,**settings)`
	`617`	`+try:`
	`618`	`+result=self.session.send(prepped,timeout=timeout,**settings)`
	`619`	`+exceptrequests.RequestException:`
	`620`	`+ifretry_transient_errorsand (`
	`621`	`+max_retries==-1orcur_retries<max_retries`
	`622`	`+ ):`
	`623`	`+wait_time=2*cur_retries0.1`
	`624`	`+cur_retries+=1`
	`625`	`+time.sleep(wait_time)`
	`626`	`+continue`
	`627`	`+`
	`628`	`+raise`
`615`	`629`
`616`	`630`	`self._check_redirects(result)`
`617`	`631`
`618`	`632`	`if200<=result.status_code<300:`
`619`	`633`	`returnresult`
`620`	`634`
`621`		`-retry_transient_errors=kwargs.get(`
`622`		`-"retry_transient_errors",self.retry_transient_errors`
`623`		`- )`
`624`	`635`	`if (429==result.status_codeandobey_rate_limit)or (`
`625`	`636`	`result.status_codein [500,502,503,504]andretry_transient_errors`
`626`	`637`	`):`

Comments

(0)