test: Test with singer-sdk @ main

pyproject.toml

@@ -33,7 +33,7 @@ packages = [
 [tool.poetry.dependencies]
 python = "<3.13,>=3.8"
 requests = "^2.25.1"
-singer-sdk = ">=0.28,<0.35"
+singer-sdk = {git = "https://github.com/meltano/sdk.git"}
 psycopg2-binary = "2.9.9"
 sqlalchemy = ">=2.0,<3.0"
 sshtunnel = "0.4.0"

target_postgres/connector.py

@@ -83,7 +83,7 @@ def prepare_table(  # type: ignore[override]
         self,
         full_table_name: str,
         schema: dict,
-        primary_keys: list[str],
+        primary_keys: t.Sequence[str],
         connection: sa.engine.Connection,
         partition_keys: list[str] | None = None,
         as_temp_table: bool = False,
@@ -316,7 +316,7 @@ def create_empty_table(  # type: ignore[override]
         meta: sa.MetaData,
         schema: dict,
         connection: sa.engine.Connection,
-        primary_keys: list[str] | None = None,
+        primary_keys: t.Sequence[str] | None = None,
         partition_keys: list[str] | None = None,
         as_temp_table: bool = False,
     ) -> sa.Table:

target_postgres/sinks.py

@@ -1,7 +1,7 @@
 """Postgres target sink class, which handles writing streams."""
 
 import uuid
-from typing import Any, Dict, Iterable, List, Optional, Union, cast
+from typing import Any, Dict, Iterable, List, Optional, Sequence, Union, cast
 
 import sqlalchemy as sa
 from pendulum import now
@@ -121,7 +121,7 @@ def bulk_insert_records(  # type: ignore[override]
         table: sa.Table,
         schema: dict,
         records: Iterable[Dict[str, Any]],
-        primary_keys: List[str],
+        primary_keys: Sequence[str],
         connection: sa.engine.Connection,
     ) -> Optional[int]:
         """Bulk insert records to an existing destination table.
@@ -178,7 +178,7 @@ def upsert(
         from_table: sa.Table,
         to_table: sa.Table,
         schema: dict,
-        join_keys: List[str],
+        join_keys: Sequence[str],
         connection: sa.engine.Connection,
     ) -> Optional[int]:
         """Merge upsert data from one table to another.

target_postgres/tests/test_target_postgres.py

@@ -1,17 +1,15 @@
 """ Postgres target tests """
 # flake8: noqa
 import copy
-import datetime
 import io
 from contextlib import redirect_stdout
 from decimal import Decimal
 from pathlib import Path
 
-import jsonschema
 import pytest
 import sqlalchemy
-from singer_sdk.exceptions import MissingKeyPropertiesError
-from singer_sdk.testing import get_target_test_class, sync_end_to_end
+from singer_sdk.exceptions import InvalidRecord, MissingKeyPropertiesError
+from singer_sdk.testing import sync_end_to_end
 from sqlalchemy.dialects.postgresql import ARRAY
 from sqlalchemy.types import TEXT, TIMESTAMP
 
@@ -234,8 +232,8 @@ def test_record_missing_key_property(postgres_target):
 
 
 def test_record_missing_required_property(postgres_target):
-    with pytest.raises(jsonschema.exceptions.ValidationError):
-        file_name = "record_missing_required_property.singer"
+    file_name = "record_missing_required_property.singer"
+    with pytest.raises(InvalidRecord):
         singer_file_to_target(file_name, postgres_target)