diff --git a/python/datafusion/record_batch.py b/python/datafusion/record_batch.py
index a2ad850c..633e341f 100644
--- a/python/datafusion/record_batch.py
+++ b/python/datafusion/record_batch.py
@@ -63,7 +63,7 @@ def next(self) -> RecordBatch | None:
 
     async def __anext__(self) -> RecordBatch:
         """Async iterator function."""
-        next_batch = self.rbs.__anext__()
+        next_batch = await self.rbs.__anext__()
         return RecordBatch(next_batch)
 
     def __next__(self) -> RecordBatch: