Test increasing ttpx connection pool.

lsst-dm · Oct 16, 2024 · c83bbd1 · c83bbd1
1 parent 4315216
commit c83bbd1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main.py b/src/main.py
@@ -525,7 +525,8 @@ async def main() -> None:
 
     tasks = set()
 
-    async with httpx.AsyncClient() as client:
+    limits = httpx.Limits(max_connections=160)
+    async with httpx.AsyncClient(limits=limits) as client:
 
         try:
             # Setup kafka schema registry connection and deserialzer