From df514cfd6ef6d0b2536434150cb32fbecf2c60a2 Mon Sep 17 00:00:00 2001
From: Kevin Hu <6051736+kevinhu@users.noreply.github.com>
Date: Thu, 21 Apr 2022 16:43:29 -0700
Subject: [PATCH] feat(ingest): mysql - add decimal128 custom type (#4624)

---
 metadata-ingestion/src/datahub/ingestion/source/sql/mysql.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/metadata-ingestion/src/datahub/ingestion/source/sql/mysql.py b/metadata-ingestion/src/datahub/ingestion/source/sql/mysql.py
index a6080ccfcd..50a108d53b 100644
--- a/metadata-ingestion/src/datahub/ingestion/source/sql/mysql.py
+++ b/metadata-ingestion/src/datahub/ingestion/source/sql/mysql.py
@@ -14,16 +14,19 @@ GEOMETRY = make_sqlalchemy_type("GEOMETRY")
 POINT = make_sqlalchemy_type("POINT")
 LINESTRING = make_sqlalchemy_type("LINESTRING")
 POLYGON = make_sqlalchemy_type("POLYGON")
+DECIMAL128 = make_sqlalchemy_type("DECIMAL128")
 
 register_custom_type(GEOMETRY)
 register_custom_type(POINT)
 register_custom_type(LINESTRING)
 register_custom_type(POLYGON)
+register_custom_type(DECIMAL128)
 
 base.ischema_names["geometry"] = GEOMETRY
 base.ischema_names["point"] = POINT
 base.ischema_names["linestring"] = LINESTRING
 base.ischema_names["polygon"] = POLYGON
+base.ischema_names["decimal128"] = DECIMAL128
 
 
 class MySQLConfig(BasicSQLAlchemyConfig):