We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
information_schema
pg_catalog
1 parent 492ccb1 commit 96ce2d0Copy full SHA for 96ce2d0
tap_postgres/tap.py
@@ -39,6 +39,11 @@ class TapPostgres(SQLTap):
39
package_name = "meltanolabs-tap-postgres"
40
default_stream_class = PostgresStream
41
42
+ exclude_schemas = (
43
+ "information_schema",
44
+ "pg_catalog",
45
+ )
46
+
47
def __init__(
48
self,
49
*args,
@@ -561,7 +566,11 @@ def catalog_dict(self) -> dict:
561
566
return self.input_catalog.to_dict()
562
567
563
568
result: dict[str, list[dict]] = {"streams": []}
564
- result["streams"].extend(self.connector.discover_catalog_entries())
569
+ result["streams"].extend(
570
+ self.connector.discover_catalog_entries(
571
+ exclude_schemas=self.exclude_schemas,
572
573
565
574
575
self._catalog_dict: dict = result
576
return self._catalog_dict
0 commit comments