File tree Expand file tree Collapse file tree 1 file changed +9
-14
lines changed
Expand file tree Collapse file tree 1 file changed +9
-14
lines changed Original file line number Diff line number Diff line change @@ -1087,21 +1087,16 @@ def add_entry(self, entry: ManifestEntry) -> ManifestWriter:
10871087 return self
10881088
10891089 def add (self , entry : ManifestEntry ) -> ManifestWriter :
1090- if entry .sequence_number is not None and entry .sequence_number >= 0 :
1091- self .add_entry (
1092- ManifestEntry .from_args (
1093- status = ManifestEntryStatus .ADDED ,
1094- snapshot_id = self ._snapshot_id ,
1095- sequence_number = entry .sequence_number ,
1096- data_file = entry .data_file ,
1097- )
1098- )
1099- else :
1100- self .add_entry (
1101- ManifestEntry .from_args (
1102- status = ManifestEntryStatus .ADDED , snapshot_id = self ._snapshot_id , data_file = entry .data_file
1103- )
1090+ self .add_entry (
1091+ ManifestEntry .from_args (
1092+ status = ManifestEntryStatus .ADDED ,
1093+ snapshot_id = self ._snapshot_id ,
1094+ sequence_number = entry .sequence_number if entry .file_sequence_number != UNASSIGNED_SEQ else None ,
1095+ file_sequence_number = entry .file_sequence_number if entry .file_sequence_number != UNASSIGNED_SEQ else None ,
1096+ data_file = entry .data_file ,
11041097 )
1098+ )
1099+
11051100 return self
11061101
11071102 def delete (self , entry : ManifestEntry ) -> ManifestWriter :
You can’t perform that action at this time.
0 commit comments