Commit46acfbf

committed

handled timeout error

1 parent5253fd0 commit46acfbfCopy full SHA for 46acfbf

File tree

+15

-9

lines changed

+15

-9

lines changed

Lines changed: 6 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -204,9 +204,12 @@ def getBatchDetails(`
`204`	`204`	`chunk=lookup_addresses[i :i+batch_size]`
`205`	`205`
`206`	`206`	`# lookup`
`207`		`-response=requests.post(`
`208`		`-url,json=chunk,headers=headers,**req_opts`
`209`		`- )`
	`207`	`+try:`
	`208`	`+response=requests.post(`
	`209`	`+url,json=chunk,headers=headers,**req_opts`
	`210`	`+ )`
	`211`	`+exceptExceptionase:`
	`212`	`+returnhandler_utils.return_or_fail(raise_on_fail,e,result)`
`210`	`213`
`211`	`214`	`# fail on bad status codes`
`212`	`215`	`try:`

Lines changed: 9 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -264,12 +264,15 @@ async def _do_batch_req(`
`264`	`264`	`"""`
`265`	`265`	`Coroutine which will do the actual POST request for getBatchDetails.`
`266`	`266`	`"""`
`267`		`-resp=awaitself.httpsess.post(`
`268`		`-url,`
`269`		`-data=json.dumps(chunk),`
`270`		`-headers=headers,`
`271`		`-timeout=timeout_per_batch,`
`272`		`- )`
	`267`	`+try:`
	`268`	`+resp=awaitself.httpsess.post(`
	`269`	`+url,`
	`270`	`+data=json.dumps(chunk),`
	`271`	`+headers=headers,`
	`272`	`+timeout=timeout_per_batch,`
	`273`	`+ )`
	`274`	`+exceptExceptionase:`
	`275`	`+returnhandler_utils.return_or_fail(raise_on_fail,e,None)`
`273`	`276`
`274`	`277`	`# gather data`
`275`	`278`	`try:`

Comments

(0)