diff options
| author | Cédric Bonhomme <cedric@cedricbonhomme.org> | 2019-05-21 23:51:25 +0200 |
|---|---|---|
| committer | Cédric Bonhomme <cedric@cedricbonhomme.org> | 2019-05-21 23:51:25 +0200 |
| commit | 7cb0295b198966bfe4e32a2b6e4200db49272f66 (patch) | |
| tree | 6c1064ded3bead567045c8e68661817f54271f35 | |
| parent | Do not update existing articles. (diff) | |
| download | newspipe-7cb0295b198966bfe4e32a2b6e4200db49272f66.tar.gz newspipe-7cb0295b198966bfe4e32a2b6e4200db49272f66.tar.bz2 newspipe-7cb0295b198966bfe4e32a2b6e4200db49272f66.zip | |
Updated max size of the asyncio queue.
| -rwxr-xr-x | src/manager.py | 2 |
1 files changed, 1 insertions, 1 deletions
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) |