diff --git a/tap_postgres/tap.py b/tap_postgres/tap.py index 0e1e48f..4cdab8a 100644 --- a/tap_postgres/tap.py +++ b/tap_postgres/tap.py @@ -42,6 +42,11 @@ class TapPostgres(SQLTap): name = "tap-postgres" default_stream_class = PostgresStream + exclude_schemas = ( + "information_schema", + "pg_catalog", + ) + def __init__( self, *args, @@ -547,7 +552,11 @@ def catalog_dict(self) -> dict: return self.input_catalog.to_dict() result: dict[str, list[dict]] = {"streams": []} - result["streams"].extend(self.connector.discover_catalog_entries()) + result["streams"].extend( + self.connector.discover_catalog_entries( + exclude_schemas=self.exclude_schemas, + ) + ) self._catalog_dict: dict = result return self._catalog_dict