diff --git a/src/snowflake/snowpark/_internal/analyzer/datatype_mapper.py b/src/snowflake/snowpark/_internal/analyzer/datatype_mapper.py index 99bccdca1d..c824927ec9 100644 --- a/src/snowflake/snowpark/_internal/analyzer/datatype_mapper.py +++ b/src/snowflake/snowpark/_internal/analyzer/datatype_mapper.py @@ -518,8 +518,6 @@ def schema_expression(data_type: DataType, is_nullable: bool) -> str: return "PARSE_JSON('NULL') :: VARIANT" return "NULL :: " + convert_sp_to_sf_type(data_type) - if isinstance(data_type, DecFloatType): - return "DECFLOAT '0'" if isinstance(data_type, _NumericType): return "0 :: " + convert_sp_to_sf_type(data_type) if isinstance(data_type, StringType): diff --git a/tests/unit/test_datatype_mapper.py b/tests/unit/test_datatype_mapper.py index 3df7de666a..7ce9a25363 100644 --- a/tests/unit/test_datatype_mapper.py +++ b/tests/unit/test_datatype_mapper.py @@ -770,6 +770,7 @@ def test_schema_expression(): assert schema_expression(LongType(), False) == "0 :: BIGINT" assert schema_expression(FloatType(), False) == "0 :: FLOAT" assert schema_expression(DoubleType(), False) == "0 :: DOUBLE" + assert schema_expression(DecFloatType(), False) == "0 :: DECFLOAT" assert schema_expression(StringType(), False) == "'a' :: STRING" assert schema_expression(StringType(19), False) == "'a' :: STRING (19)" assert schema_expression(BooleanType(), False) == "true"