diff --git a/posthog/temporal/data_imports/pipelines/sql_database/__init__.py b/posthog/temporal/data_imports/pipelines/sql_database/__init__.py index a3524f378e1a7..d5902480986f1 100644 --- a/posthog/temporal/data_imports/pipelines/sql_database/__init__.py +++ b/posthog/temporal/data_imports/pipelines/sql_database/__init__.py @@ -201,7 +201,7 @@ def get_column_hints(engine: Engine, schema_name: str, table_name: str) -> dict[ columns[column_name] = { "data_type": "decimal", "precision": numeric_precision or 76, - "scale": numeric_scale or 16, + "scale": numeric_scale or 32, } return columns diff --git a/posthog/temporal/data_imports/pipelines/sql_database/test/test_sql_database.py b/posthog/temporal/data_imports/pipelines/sql_database/test/test_sql_database.py index d604d1e38c35b..edf217c4a67a4 100644 --- a/posthog/temporal/data_imports/pipelines/sql_database/test/test_sql_database.py +++ b/posthog/temporal/data_imports/pipelines/sql_database/test/test_sql_database.py @@ -35,7 +35,7 @@ def test_get_column_hints_numeric_with_missing_scale_and_precision(): mock_engine = _setup([("column", "numeric", None, None)]) assert get_column_hints(mock_engine, "some_schema", "some_table") == { - "column": {"data_type": "decimal", "precision": 76, "scale": 16} + "column": {"data_type": "decimal", "precision": 76, "scale": 32} }