Skip to content
This repository was archived by the owner on May 17, 2024. It is now read-only.

Commit 26485d7

Browse files
committed
Fix databricks schema handling
1 parent 5659b73 commit 26485d7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

data_diff/databases/databricks.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -187,7 +187,7 @@ def _process_table_schema(
187187
resulted_rows = []
188188
for info in col_infos:
189189
raw_data_type = info.data_type
190-
row_type = "DECIMAL" if info.data_type.startswith("DECIMAL") else info.data_type
190+
row_type = info.data_type.split("(")[0]
191191
info = attrs.evolve(info, data_type=row_type)
192192
type_cls = self.dialect.TYPE_CLASSES.get(row_type, UnknownColType)
193193

0 commit comments

Comments
 (0)