From b45dec23b79714b1832f6d659dd3e412e4918348 Mon Sep 17 00:00:00 2001 From: "David H. Irving" Date: Thu, 29 Aug 2024 16:03:54 -0700 Subject: [PATCH] try increasing queue size --- .../daf/butler/remote_butler/server/handlers/_external_query.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/lsst/daf/butler/remote_butler/server/handlers/_external_query.py b/python/lsst/daf/butler/remote_butler/server/handlers/_external_query.py index 3b5f627b61..e24a9b808f 100644 --- a/python/lsst/daf/butler/remote_butler/server/handlers/_external_query.py +++ b/python/lsst/daf/butler/remote_butler/server/handlers/_external_query.py @@ -129,7 +129,7 @@ async def _stream_query_pages( # exit_stack. async with contextmanager_in_threadpool(exit_stack): # `None` signals that there is no more data to send. - queue = asyncio.Queue[QueryExecuteResultData | None](1) + queue = asyncio.Queue[QueryExecuteResultData | None](2) async with asyncio.TaskGroup() as tg: tg.create_task(_enqueue_query_pages(ctx, spec, queue)) async for message in _dequeue_query_pages_with_keepalive(queue):