diff --git a/data_diff/databases/redshift.py b/data_diff/databases/redshift.py index be9ec0fb..d7bcd876 100644 --- a/data_diff/databases/redshift.py +++ b/data_diff/databases/redshift.py @@ -181,7 +181,7 @@ def _normalize_schema_info(self, rows: Iterable[Tuple[Any]]) -> Dict[str, RawCol schema_dict[col_name] = RawColumnInfo( column_name=col_name, - data_type=col_name, + data_type=base_type, datetime_precision=None, numeric_precision=precision, numeric_scale=scale,