Skip to content

Commit

Permalink
test: Test with singer-sdk @ main
Browse files Browse the repository at this point in the history
  • Loading branch information
edgarrmondragon committed Jul 25, 2024
1 parent 03c428e commit e6d8190
Show file tree
Hide file tree
Showing 3 changed files with 23 additions and 20 deletions.
33 changes: 18 additions & 15 deletions poetry.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 2 additions & 2 deletions pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ packages = [
[tool.poetry.dependencies]
python = ">=3.8"
cryptography = ">=40,<43"
singer-sdk = "~=0.38.0"
singer-sdk = { git = "https://github.com/meltano/sdk.git" }
snowflake-sqlalchemy = "~=1.6.1"
snowflake-connector-python = { version = "<4.0.0", extras = ["secure-local-storage"] }
sqlalchemy = "<2"
Expand All @@ -25,7 +25,7 @@ sqlalchemy = "<2"
coverage = ">=7.2.7"
pytest = ">=7.4.3"
pytest-xdist = ">=3.3.1"
singer-sdk = { version="~=0.38.0", extras = ["testing"] }
singer-sdk = { git = "https://github.com/meltano/sdk.git", extras = ["testing"] }

[tool.ruff]
line-length = 120
Expand Down
6 changes: 3 additions & 3 deletions target_snowflake/sinks.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,15 +21,15 @@
from target_snowflake.connector import SnowflakeConnector

if t.TYPE_CHECKING:
from singer_sdk import PluginBase, SQLConnector
from singer_sdk import PluginBase

DEFAULT_BATCH_CONFIG = {
"encoding": {"format": "jsonl", "compression": "gzip"},
"storage": {"root": "file://"},
}


class SnowflakeSink(SQLSink):
class SnowflakeSink(SQLSink[SnowflakeConnector]):
"""Snowflake target sink class."""

connector_class = SnowflakeConnector
Expand All @@ -40,7 +40,7 @@ def __init__(
stream_name: str,
schema: dict,
key_properties: list[str] | None,
connector: SQLConnector | None = None,
connector: SnowflakeConnector | None = None,
) -> None:
"""Initialize Snowflake Sink."""
self.target = target
Expand Down

0 comments on commit e6d8190

Please sign in to comment.