fix: add missing pipeline sync in async cursro scroll().

diff --git a/docs/news.rst b/docs/news.rst
index fc823cf32f3dca1984945b25372f905b41193565..b1340071036933076ab673bb57f2905705281041 100644 (file)
--- a/docs/news.rst
+++ b/docs/news.rst
@@ -34,6 +34,7 @@ Psycopg 3.1.11 (unreleased)
 - Fix integer overflow in C/binary extension with OID > 2^31 (:ticket:`#630`).
 - Fix possible lack of critical section guard in async
   `~AsyncCursor.executemany()`.
+- Fix missing pipeline fetch in async `~AsyncCursor.scroll()`.
 
 
 Current release

diff --git a/psycopg/psycopg/cursor_async.py b/psycopg/psycopg/cursor_async.py
index 78acf409ec30dd0b23462b0aecd397df3205d931..58fce6420a7fef0bc1d04d39a60c616c0eea81a4 100644 (file)
--- a/psycopg/psycopg/cursor_async.py
+++ b/psycopg/psycopg/cursor_async.py
@@ -216,6 +216,7 @@ class AsyncCursor(BaseCursor["AsyncConnection[Any]", Row]):
             yield row
 
     async def scroll(self, value: int, mode: str = "relative") -> None:
+        await self._fetch_pipeline()
         self._scroll(value, mode)
 
     @asynccontextmanager