test: Test with singer-sdk @ main

pyproject.toml

@@ -39,7 +39,7 @@ sqlalchemy = "2.0.36"
 sshtunnel = "0.4.0"
 
 [tool.poetry.dependencies.singer-sdk]
-version = "~=0.42.1"
+git = "https://github.com/meltano/sdk.git"
 extras = ["faker"]
 
 [tool.poetry.group.dev.dependencies]
@@ -57,7 +57,7 @@ types-jsonschema = ">=4.19.0.3"
 types-psycopg2 = ">=2.9.21.20240118"
 
 [tool.poetry.dev-dependencies.singer-sdk]
-version = "*"
+git = "https://github.com/meltano/sdk.git"
 extras = ["testing"]
 
 [tool.mypy]

tap_postgres/client.py

@@ -35,12 +35,20 @@
 class PostgresSQLToJSONSchema(SQLToJSONSchema):
     """Custom SQL to JSON Schema conversion for Postgres."""
 
-    def __init__(self, dates_as_string: bool, json_as_object: bool, *args, **kwargs):
+    def __init__(self, *, dates_as_string: bool, json_as_object: bool, **kwargs):
         """Initialize the SQL to JSON Schema converter."""
-        super().__init__(*args, **kwargs)
+        super().__init__(**kwargs)
         self.dates_as_string = dates_as_string
         self.json_as_object = json_as_object
 
+    @classmethod
+    def from_config(cls, config: dict) -> PostgresSQLToJSONSchema:
+        """Instantiate the SQL to JSON Schema converter from a config dictionary."""
+        return cls(
+            dates_as_string=config["dates_as_string"],
+            json_as_object=config["json_as_object"],
+        )
+
     @functools.singledispatchmethod
     def to_jsonschema(self, column_type: t.Any) -> dict:
         """Customize the JSON Schema for Postgres types."""
@@ -132,6 +140,8 @@ def patched_conform(elem: t.Any, property_schema: dict) -> t.Any:
 class PostgresConnector(SQLConnector):
     """Connects to the Postgres SQL source."""
 
+    sql_to_jsonschema_converter = PostgresSQLToJSONSchema
+
     def __init__(
         self,
         config: dict | None = None,
@@ -160,14 +170,6 @@ def __init__(
 
         super().__init__(config=config, sqlalchemy_url=sqlalchemy_url)
 
-    @functools.cached_property
-    def sql_to_jsonschema(self):
-        """Return a mapping of SQL types to JSON Schema types."""
-        return PostgresSQLToJSONSchema(
-            dates_as_string=self.config["dates_as_string"],
-            json_as_object=self.config["json_as_object"],
-        )
-
     def get_schema_names(self, engine: Engine, inspected: Inspector) -> list[str]:
         """Return a list of schema names in DB, or overrides with user-provided values.
 

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