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 325511d commit 6a0ce07Copy full SHA for 6a0ce07
tap_postgres/tap.py
@@ -42,6 +42,11 @@ class TapPostgres(SQLTap):
42
name = "tap-postgres"
43
default_stream_class = PostgresStream
44
45
+ exclude_schemas = (
46
+ "information_schema",
47
+ "pg_catalog",
48
+ )
49
+
50
def __init__(
51
self,
52
*args,
@@ -547,7 +552,11 @@ def catalog_dict(self) -> dict:
547
552
return self.input_catalog.to_dict()
548
553
549
554
result: dict[str, list[dict]] = {"streams": []}
550
- result["streams"].extend(self.connector.discover_catalog_entries())
555
+ result["streams"].extend(
556
+ self.connector.discover_catalog_entries(
557
+ exclude_schemas=self.exclude_schemas,
558
559
551
560
561
self._catalog_dict: dict = result
562
return self._catalog_dict
0 commit comments