Skip to content

Commit ab6d40b

Browse files
committed
CFR: When importing, use replace policy instead of append
1 parent 6970b7e commit ab6d40b

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

CHANGES.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
- I/O: Updated to `ingestr>=0.13.61`
55
- CFR: Improved log output
66
- CFR: Fixed double quoting of table name. Thanks, @karynzv.
7+
- CFR: When importing, use `replace` policy instead of `append`
78

89
## 2025/07/01 v0.0.37
910
- Settings: Fixed comparison of `0s` vs `0ms`. Thanks, @hlcianfagna.

cratedb_toolkit/cfr/systable.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -248,7 +248,7 @@ def _load(self, path_schema: Path, path_data: Path):
248248
# Load data.
249249
try:
250250
df: "pl.DataFrame" = self.load_table(path_table_data)
251-
df.write_database(table_name=tablename_restored, connection=self.dburi, if_table_exists="append")
251+
df.write_database(table_name=tablename_restored, connection=self.dburi, if_table_exists="replace")
252252
except Exception as ex:
253253
error_logger(self.debug)(f"Importing table failed: {tablename}. Reason: {ex}")
254254

0 commit comments

Comments
 (0)