Compare commits

...

4 Commits

Author SHA1 Message Date
68351f695a Increased page_size for fetch_cursor to 50k 2025-12-27 14:39:37 +03:00
e6860e67c2 Raised fetch_cursor limit to 10k rows 2025-12-25 22:04:52 +03:00
552264aaee Fixed TTL 2025-12-25 22:01:08 +03:00
66c7ee7a74 Fixed TTL 2025-12-25 21:55:55 +03:00

View File

@@ -69,7 +69,7 @@ async def execute_select(
@router.get(path="/fetch_cursor", dependencies=[Depends(get_current_user)])
async def fetch_cursor(
cursor_id: str,
page_size: Annotated[int, Field(ge=1, le=1000)] = 50,
page_size: Annotated[int, Field(ge=1, le=50_000)] = 50,
) -> SelectResult:
cached_cursor = mysql.cached_cursors.get(cursor_id, None)
if cached_cursor is None:
@@ -78,6 +78,8 @@ async def fetch_cursor(
if cached_cursor.done:
mysql.cached_cursors.pop(cursor_id, None)
else:
cached_cursor.close_at = cached_cursor.upgrade_close_at()
return SelectResult(
cursor=cached_cursor,