Skip to content

Commit a7d1ee0

Browse files
committed
add column names to to_delete_rows
1 parent a7cfa07 commit a7d1ee0

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

genie/process_functions.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -541,7 +541,8 @@ def _delete_rows(new_datasetdf, databasedf, checkby):
541541
if not deletedf.empty:
542542
logger.info("Deleting Rows")
543543
delete_rowid_version = pd.DataFrame(
544-
[[rowid.split("_")[0], rowid.split("_")[1]] for rowid in deletedf.index]
544+
[[rowid.split("_")[0], rowid.split("_")[1]] for rowid in deletedf.index],
545+
columns=["ROW_ID", "ROW_VERSION"],
545546
)
546547
delete_rowid_version.reset_index(drop=True, inplace=True)
547548
else:

0 commit comments

Comments
 (0)