File tree 1 file changed +3
-2
lines changed
1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -926,12 +926,12 @@ def __exit__(
926
926
self ._current_writer .__exit__ (exc_type , exc_value , traceback )
927
927
928
928
def _get_current_writer (self ) -> ManifestWriter :
929
+ if self ._should_roll_to_new_file ():
930
+ self ._close_current_writer ()
929
931
if not self ._current_writer :
930
932
self ._current_writer = next (self ._supplier )
931
933
self ._current_writer .__enter__ ()
932
934
return self ._current_writer
933
- if self ._should_roll_to_new_file ():
934
- self ._close_current_writer ()
935
935
return self ._current_writer
936
936
937
937
def _should_roll_to_new_file (self ) -> bool :
@@ -958,6 +958,7 @@ def add_entry(self, entry: ManifestEntry) -> RollingManifestWriter:
958
958
if self ._closed :
959
959
raise RuntimeError ("Cannot add entry to closed manifest writer" )
960
960
self ._get_current_writer ().add_entry (entry )
961
+ self ._current_file_rows += entry .data_file .record_count
961
962
return self
962
963
963
964
You can’t perform that action at this time.
0 commit comments