From a275fe9522cf750a0ebfa09bfd5c056a4e38c81a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lauri=20V=C3=B5sandi?= Date: Wed, 24 Aug 2022 23:02:36 +0300 Subject: [PATCH] Reduce queue sizes --- camdetect.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/camdetect.py b/camdetect.py index 0156071..d2eae85 100755 --- a/camdetect.py +++ b/camdetect.py @@ -537,8 +537,8 @@ async def setup_db(app, loop): signal.signal(signal.SIGUSR1, handler) # Set up processing pipeline - download_queue = asyncio.Queue(200) - upload_queue = asyncio.Queue(200) + download_queue = asyncio.Queue(50) + upload_queue = asyncio.Queue(50) asyncio.create_task(uploader( upload_queue)) asyncio.create_task(downloader(