Discover partitioned tables (#99)

transferwise · Jun 23, 2021 · ec7d5f0 · ec7d5f0
1 parent 8c4732e
commit ec7d5f0
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,8 @@
+1.8.0 (2021-06-23)
+-------------------
+
+- Add discovering of partitioned tables.
+
 1.7.1 (2020-10-13)
 -------------------
 

diff --git a/setup.py b/setup.py
@@ -6,7 +6,7 @@
     long_description = f.read()
 
 setup(name='pipelinewise-tap-postgres',
-      version='1.7.1',
+      version='1.8.0',
       description='Singer.io tap for extracting data from PostgresSQL - PipelineWise compatible',
       long_description=long_description,
       long_description_content_type='text/markdown',

diff --git a/tap_postgres/discovery_utils.py b/tap_postgres/discovery_utils.py
@@ -103,7 +103,7 @@ def produce_table_info(conn, filter_schemas=None, tables: Optional[List[str]] =
  AND pgt.typelem != 0
 WHERE attnum > 0
 AND NOT a.attisdropped
-AND pg_class.relkind IN ('r', 'v', 'm')
+AND pg_class.relkind IN ('r', 'v', 'm', 'p')
 AND n.nspname NOT in ('pg_toast', 'pg_catalog', 'information_schema')
 AND has_column_privilege(pg_class.oid, attname, 'SELECT') = true """