Await fix.
This commit is contained in:
parent
6343513980
commit
34f05e5992
@ -32,7 +32,7 @@ async def get_recent_rants(start_from=1, page_size=10):
|
|||||||
def get_rants():
|
def get_rants():
|
||||||
return dr.get_rants("recent", page_size, start_from)["rants"]
|
return dr.get_rants("recent", page_size, start_from)["rants"]
|
||||||
|
|
||||||
rants = asyncio.wait_for(loop.run_in_executor(None,get_rants), 15)
|
rants = await asyncio.wait_for(loop.run_in_executor(None,get_rants), 15)
|
||||||
|
|
||||||
page += 1
|
page += 1
|
||||||
for rant in rants:
|
for rant in rants:
|
||||||
|
Loading…
Reference in New Issue
Block a user