added timeout param for wait_for
This commit is contained in:
parent
cda863b0bc
commit
6a92cf9ec9
1 changed files with 4 additions and 1 deletions
|
|
@ -438,7 +438,10 @@ class HttpAPI(common):
|
||||||
return web.json_response(data={"error": str(e), "data": item}, status=web.HTTPBadRequest.status_code)
|
return web.json_response(data={"error": str(e), "data": item}, status=web.HTTPBadRequest.status_code)
|
||||||
|
|
||||||
return web.json_response(
|
return web.json_response(
|
||||||
data=await asyncio.wait_for(asyncio.gather(*[self.add(**self.format_item(item)) for item in data])),
|
data=await asyncio.wait_for(
|
||||||
|
fut=asyncio.gather(*[self.add(**self.format_item(item)) for item in data]),
|
||||||
|
timeout=None,
|
||||||
|
),
|
||||||
status=web.HTTPOk.status_code,
|
status=web.HTTPOk.status_code,
|
||||||
dumps=self.encoder.encode,
|
dumps=self.encoder.encode,
|
||||||
)
|
)
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue