Skip to content

Commit

Permalink
chore: Bump singer-sdk from 0.34.1 to 0.35.0 (#290)
Browse files Browse the repository at this point in the history
  • Loading branch information
dependabot[bot] authored Feb 6, 2024
1 parent 93429c7 commit 1f7b73d
Show file tree
Hide file tree
Showing 5 changed files with 19 additions and 40 deletions.
43 changes: 11 additions & 32 deletions poetry.lock

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

2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ sqlalchemy = "~=2.0"
sshtunnel = "0.4.0"

[tool.poetry.dependencies.singer-sdk]
version = "~=0.34.0"
version = "~=0.35.0"

[tool.poetry.group.dev.dependencies]
pytest = ">=7.4.2"
Expand Down
4 changes: 2 additions & 2 deletions target_postgres/connector.py
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down Expand Up @@ -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:
Expand Down
6 changes: 3 additions & 3 deletions target_postgres/sinks.py
Original file line number Diff line number Diff line change
@@ -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
Expand Down Expand Up @@ -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.
Expand Down Expand Up @@ -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.
Expand Down
4 changes: 2 additions & 2 deletions target_postgres/tests/test_target_postgres.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
import jsonschema
import pytest
import sqlalchemy
from singer_sdk.exceptions import MissingKeyPropertiesError
from singer_sdk.exceptions import InvalidRecord, MissingKeyPropertiesError
from singer_sdk.testing import get_target_test_class, sync_end_to_end
from sqlalchemy.dialects.postgresql import ARRAY
from sqlalchemy.types import TEXT, TIMESTAMP
Expand Down Expand Up @@ -234,7 +234,7 @@ def test_record_missing_key_property(postgres_target):


def test_record_missing_required_property(postgres_target):
with pytest.raises(jsonschema.exceptions.ValidationError):
with pytest.raises(InvalidRecord):
file_name = "record_missing_required_property.singer"
singer_file_to_target(file_name, postgres_target)

Expand Down

0 comments on commit 1f7b73d

Please sign in to comment.