test: Test with singer-sdk @ main

Author: edgarrmondragon

poetry.lock

@@ -37,7 +37,7 @@ sqlalchemy = "~=2.0"
 sshtunnel = "0.4.0"
 
 [tool.poetry.dependencies.singer-sdk]
-version = "~=0.39.0"
+git = "https://github.com/meltano/sdk.git"
 
 [tool.poetry.group.dev.dependencies]
 pytest = ">=7.4.2"

pyproject.toml

@@ -33,6 +33,9 @@
 )
 from sshtunnel import SSHTunnelForwarder
 
+if t.TYPE_CHECKING:
+    from singer_sdk.connectors.sql import FullyQualifiedName
+
 
 class PostgresConnector(SQLConnector):
     """Sets up SQL Alchemy, and other Postgres related stuff."""
@@ -94,7 +97,7 @@ def interpret_content_encoding(self) -> bool:
 
     def prepare_table(  # type: ignore[override]
         self,
-        full_table_name: str,
+        full_table_name: str | FullyQualifiedName,
         schema: dict,
         primary_keys: t.Sequence[str],
         connection: sa.engine.Connection,
@@ -156,7 +159,7 @@ def prepare_table(  # type: ignore[override]
 
     def copy_table_structure(
         self,
-        full_table_name: str,
+        full_table_name: str | FullyQualifiedName,
         from_table: sa.Table,
         connection: sa.engine.Connection,
         as_temp_table: bool = False,
@@ -426,7 +429,7 @@ def create_empty_table(  # type: ignore[override]
 
     def prepare_column(
         self,
-        full_table_name: str,
+        full_table_name: str | FullyQualifiedName,
         column_name: str,
         sql_type: sa.types.TypeEngine,
         connection: sa.engine.Connection | None = None,
@@ -846,7 +849,7 @@ def get_table_columns(  # type: ignore[override]
 
     def column_exists(  # type: ignore[override]
         self,
-        full_table_name: str,
+        full_table_name: str | FullyQualifiedName,
         column_name: str,
         connection: sa.engine.Connection,
     ) -> bool:

target_postgres/connector.py

@@ -1,8 +1,20 @@
 """Postgres target sink class, which handles writing streams."""
 
+from __future__ import annotations
+
 import datetime
 import uuid
-from typing import Any, Dict, Iterable, List, Optional, Sequence, Union, cast
+from typing import (
+    TYPE_CHECKING,
+    Any,
+    Dict,
+    Iterable,
+    List,
+    Optional,
+    Sequence,
+    Union,
+    cast,
+)
 
 import sqlalchemy as sa
 from singer_sdk.sinks import SQLSink
@@ -11,6 +23,9 @@
 
 from target_postgres.connector import PostgresConnector
 
+if TYPE_CHECKING:
+    from singer_sdk.connectors.sql import FullyQualifiedName
+
 
 class PostgresSink(SQLSink):
     """Postgres target sink class."""
@@ -261,7 +276,7 @@ def column_representation(
 
     def generate_insert_statement(
         self,
-        full_table_name: str,
+        full_table_name: str | FullyQualifiedName,
         columns: List[sa.Column],  # type: ignore[override]
     ) -> Union[str, Executable]:
         """Generate an insert statement for the given records.

target_postgres/sinks.py

@@ -2,17 +2,15 @@
 
 # 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 InvalidRecord, MissingKeyPropertiesError
-from singer_sdk.testing import get_target_test_class, sync_end_to_end
+from singer_sdk.testing import sync_end_to_end
 from sqlalchemy.dialects.postgresql import ARRAY
 from sqlalchemy.types import TEXT, TIMESTAMP