Reduce queue sizes
Some checks reported errors
continuous-integration/drone Build was killed

This commit is contained in:
Lauri Võsandi 2022-08-24 23:02:36 +03:00
parent e54ad1ddb7
commit a275fe9522

View File

@ -537,8 +537,8 @@ async def setup_db(app, loop):
signal.signal(signal.SIGUSR1, handler) signal.signal(signal.SIGUSR1, handler)
# Set up processing pipeline # Set up processing pipeline
download_queue = asyncio.Queue(200) download_queue = asyncio.Queue(50)
upload_queue = asyncio.Queue(200) upload_queue = asyncio.Queue(50)
asyncio.create_task(uploader( asyncio.create_task(uploader(
upload_queue)) upload_queue))
asyncio.create_task(downloader( asyncio.create_task(downloader(