k-space/camera-motion-detect
10
0
Fork 0
Code Issues 2 Pull Requests Projects Activity

Set download and upload queue size limits
All checks were successful
continuous-integration/drone Build is passing
Details

Browse Source
This commit is contained in:
Lauri Võsandi 2022-07-28 23:41:26 +03:00
parent 4814030936
commit 5fb3eb4541
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
camdetect.py
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() download_queue = asyncio.Queue(200)
upload_queue = asyncio.Queue() upload_queue = asyncio.Queue(200)
asyncio.create_task(uploader( asyncio.create_task(uploader(
upload_queue)) upload_queue))
asyncio.create_task(downloader( asyncio.create_task(downloader(