From a8c2bfa4a9598821108c765808987a140bb77414 Mon Sep 17 00:00:00 2001 From: Kyle Allan Date: Tue, 8 Oct 2019 19:17:28 +0000 Subject: [PATCH] encountering a wal2json decimal needs to be string --- tap_postgres/sync_strategies/logical_replication.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tap_postgres/sync_strategies/logical_replication.py b/tap_postgres/sync_strategies/logical_replication.py index bddf10c..d2f47aa 100644 --- 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):