diff --git a/app/operations.py b/app/operations.py
index 29a8f49..77548a7 100644
--- a/app/operations.py
+++ b/app/operations.py
@@ -78,6 +78,8 @@ async def fetch_cursor(
 
     if cached_cursor.done:
         mysql.cached_cursors.pop(cursor_id, None)
+    else:
+        cached_cursor.upgrade_close_at()
 
     return SelectResult(
         cursor=cached_cursor,