fix(target-s3-parquet): add a function to conver Decimal values

Author: Marcos314

target_s3_parquet/sanitizer.py

@@ -2,12 +2,18 @@
 import numpy as np
 import json
 from typing import List
-
+from decimal import Decimal
 
 def _remove_nulls(array):
     return [v for v in array if v != "null"]
 
 
+def _convert_decimal(value):
+    if isinstance(value, Decimal):
+        return str(value)
+    return value
+
+
 def get_valid_types(types):
     if isinstance(types, list):
         return _remove_nulls(types)[0]
@@ -47,7 +53,7 @@ def apply_json_dump_to_df(
     valid_attributes = get_valid_attributes(attributes_names, df)
     if len(valid_attributes) > 0:
         for attribute in valid_attributes:
-            df.loc[:, attribute] = df[attribute].apply(lambda x: json.dumps(x))
+            df.loc[:, attribute] = df[attribute].apply(lambda x: json.dumps(x, default=_convert_decimal))
     return df