diff --git a/tap_postgres/db.py b/tap_postgres/db.py index f21dd1f..dfc2193 100644 --- a/tap_postgres/db.py +++ b/tap_postgres/db.py @@ -209,7 +209,7 @@ def hstore_available(conn_info): def compute_tap_stream_id(schema_name, table_name): - return schema_name + '-' + table_name + return table_name # NB> numeric/decimal columns in postgres without a specified scale && precision