diff --git a/camdetect.py b/camdetect.py
index 7d9c936..de1dce3 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()
-    upload_queue = asyncio.Queue()
+    download_queue = asyncio.Queue(200)
+    upload_queue = asyncio.Queue(200)
     asyncio.create_task(uploader(
         upload_queue))
     asyncio.create_task(downloader(