From 371a6a44c946616f7f7547b15305ea60b2eee2b4 Mon Sep 17 00:00:00 2001
From: joocer <justin.joyce@joocer.com>
Date: Mon, 30 Dec 2024 13:10:41 +0000
Subject: [PATCH] 0.0.177

---
 orso/converters.py | 19 +++++++++++++------
 orso/version.py    |  2 +-
 2 files changed, 14 insertions(+), 7 deletions(-)

diff --git a/orso/converters.py b/orso/converters.py
index 668b6d8..810d910 100644
--- a/orso/converters.py
+++ b/orso/converters.py
@@ -47,22 +47,29 @@ def __iter__(self):
 
     def __next__(self):
         if self.rows_processed >= self.max_size:
-            raise StopIteration
+            raise StopIteration()
 
-        try:
-            row = next(self.current_rows)
+        row = next(self.current_rows, None)
+        if row is not None:
             self.rows_processed += 1
             return row
-        except StopIteration:
+        else:
             # Fetch the next table and process it
             self.current_table = next(self.tables, None)
             if self.current_table is None:
-                raise StopIteration
+                raise StopIteration()
 
             self.current_rows = iter(
                 process_table(self.current_table, self.row_factory, self.batch_size)
             )
-            return self.__next__()
+
+            # Check if the new table has rows to process
+            row = next(self.current_rows, None)
+            if row is not None:
+                self.rows_processed += 1
+                return row
+            else:
+                raise StopIteration()
 
 
 def to_arrow(dataset, size=None):
diff --git a/orso/version.py b/orso/version.py
index c262457..2996618 100644
--- a/orso/version.py
+++ b/orso/version.py
@@ -10,5 +10,5 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-__version__: str = "0.0.176"
+__version__: str = "0.0.177"
 __author__: str = "@joocer"