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

diff --git a/docs/news.rst b/docs/news.rst
index bc770323a77b956a6f91b5baa33431a1a87b28bd..ea068839bca54df981471d6925c2c3f6552810ac 100644 (file)
--- a/docs/news.rst
+++ b/docs/news.rst
@@ -16,6 +16,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