Update python/datafusion/dataframe.py

Co-authored-by: Kyle Barron <[email protected]>

Author: kosiew

python/datafusion/dataframe.py

@@ -1147,7 +1147,7 @@ def __iter__(self) -> Iterator[RecordBatch]:
 
     def __aiter__(self) -> AsyncIterator[RecordBatch]:
         """Return an async iterator over this DataFrame's record batches."""
-        return self.execute_stream().__aiter__()
+        return aiter(self.execute_stream())
 
     def transform(self, func: Callable[..., DataFrame], *args: Any) -> DataFrame:
         """Apply a function to the current DataFrame which returns another DataFrame.