Skip to content

Commit ce81f75

Browse files
fix: Exclude information_schema and pg_catalog from discovery
1 parent b87c075 commit ce81f75

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

Diff for: tap_postgres/tap.py

+10-1
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,11 @@ class TapPostgres(SQLTap):
4242
name = "tap-postgres"
4343
default_stream_class = PostgresStream
4444

45+
exclude_schemas = (
46+
"information_schema",
47+
"pg_catalog",
48+
)
49+
4550
def __init__(
4651
self,
4752
*args,
@@ -547,7 +552,11 @@ def catalog_dict(self) -> dict:
547552
return self.input_catalog.to_dict()
548553

549554
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+
)
551560

552561
self._catalog_dict: dict = result
553562
return self._catalog_dict

0 commit comments

Comments
 (0)