Merge pull request #67 from singer-io/fix/decimal-output

Fix logical replication decimal handling
singer-io · Oct 9, 2019 · 6e6974a · 6e6974a
2 parents 9f345d6 + a8c2bfa
commit 6e6974a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tap_postgres/sync_strategies/logical_replication.py b/tap_postgres/sync_strategies/logical_replication.py
@@ -168,7 +168,7 @@ def selected_value_to_singer_value_impl(elem, og_sql_datatype, conn_info):
     if sql_datatype == 'hstore':
         return create_hstore_elem(conn_info, elem)
     if 'numeric' in sql_datatype:
-        return decimal.Decimal(elem)
+        return decimal.Decimal(str(elem))
     if isinstance(elem, int):
         return elem
     if isinstance(elem, float):