Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .github/workflows/test.yml
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ jobs:
with:
python-version: ${{ matrix.python-version }}
- name: Install uv
uses: astral-sh/setup-uv@v6
uses: astral-sh/setup-uv@v7
- name: Test with pytest
env:
UV_PYTHON: ${{ matrix.python-version }}
Expand Down
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ Built with the [Meltano Mapper SDK](https://sdk.meltano.com) for Singer Mappers.
- Adding properties pertaining to [Fivetran system columns](https://fivetran.com/docs/core-concepts/system-columns-and-tables)
- `_fivetran_id`: MD5-hash of a record, added when no `key_properties` are defined for the stream
- `_fivetran_synced`: ISO8601 timestamp of when the record was initally extracted, or otherwise processed by the mapper
- `_fivetran_deleted`: boolean to indicate soft-delete
- `_fivetran_deleted`: boolean to indicate soft-delete

<!--

Expand Down
2 changes: 2 additions & 0 deletions tests/test_stream_map.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,7 @@ def test_transform__sdc_extracted_at(stream_map: FivetranStreamMap, column_name)
assert SystemColumns.FIVETRAN_SYNCED in transformed_record
assert datetime.fromisoformat(transformed_record[SystemColumns.FIVETRAN_SYNCED])


@pytest.mark.parametrize(
"column_name",
["_sdc_extracted_at", "_SDC_EXTRACTED_AT"],
Expand Down Expand Up @@ -73,6 +74,7 @@ def test_transform__sdc_deleted_at(stream_map: FivetranStreamMap, column_name):
assert SystemColumns.FIVETRAN_DELETED in transformed_record
assert transformed_record[SystemColumns.FIVETRAN_DELETED] is True


@pytest.mark.parametrize(
"column_name",
["_sdc_deleted_at", "_SDC_DELETED_AT"],
Expand Down