From 7cb0295b198966bfe4e32a2b6e4200db49272f66 Mon Sep 17 00:00:00 2001 From: Cédric Bonhomme Date: Tue, 21 May 2019 23:51:25 +0200 Subject: Updated max size of the asyncio queue. --- src/manager.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'src') diff --git a/src/manager.py b/src/manager.py index 244ab77f..ea54cb75 100755 --- a/src/manager.py +++ b/src/manager.py @@ -68,7 +68,7 @@ def fetch_asyncio(user_id=None, feed_id=None): loop = asyncio.get_event_loop() - queue = asyncio.Queue(maxsize=2, loop=loop) + queue = asyncio.Queue(maxsize=3, loop=loop) producer_coro = default_crawler.retrieve_feed(queue, users, feed_id) consumer_coro = default_crawler.insert_articles(queue, 1) -- cgit