Skip to content

Commit e7db2c8

Browse files
committed
revert changes
1 parent e1696d7 commit e7db2c8

File tree

1 file changed

+3
-8
lines changed

1 file changed

+3
-8
lines changed

genie/process_functions.py

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -607,14 +607,9 @@ def _update_rows(new_datasetdf, databasedf, checkby):
607607
updatesetdf = updatesetdf.loc[updating_databasedf.index]
608608
# Index comparison
609609
# check row content differences only
610-
if "ROW_ID" in updatesetdf.columns and "ROW_VERSION" in updatesetdf.columns:
611-
differences = updatesetdf.drop(
612-
columns=["ROW_ID", "ROW_VERSION"]
613-
) != updating_databasedf.drop(columns=["ROW_ID", "ROW_VERSION"])
614-
else:
615-
differences = updatesetdf != updating_databasedf.drop(
616-
columns=["ROW_ID", "ROW_VERSION"]
617-
)
610+
differences = updatesetdf.drop(
611+
columns=["ROW_ID", "ROW_VERSION"]
612+
) != updating_databasedf.drop(columns=["ROW_ID", "ROW_VERSION"])
618613
differentrows = differences.apply(sum, axis=1) > 0
619614
toupdatedf = _create_update_rowsdf(updating_databasedf, updatesetdf, differentrows)
620615

0 commit comments

Comments
 (0)