|
@@ -227,14 +227,17 @@ class MigrationCleaning:
|
|
|
|
|
|
return data
|
|
|
|
|
|
+ print('THIS IS THE INVALID MASK:', invalid_mask)
|
|
|
data_inconsist = data.assign(reason=reason)\
|
|
|
.loc[invalid_mask]\
|
|
|
.reset_index(drop=True)
|
|
|
|
|
|
if db.check_if_table_exists(self._inconsist_report_table):
|
|
|
columns = db.get_column_names(tablename=self._inconsist_report_table)
|
|
|
+ print(('COLUMNS: {}, FROM {} TABLE').format(columns, self._inconsist_report_table))
|
|
|
|
|
|
if len(columns) > 0:
|
|
|
+ print('ICONSIST DATA COLUMNS:', data_inconsist.columns)
|
|
|
data_inconsist = data_inconsist[columns]
|
|
|
|
|
|
db.append_to_table(data=data_inconsist,
|