ds_provider_postgresql_py_lib.utils.dataset_identity¶

File: dataset_identity.py Region: ds_provider_postgresql_py_lib/utils/dataset_identity

Dataset Identity Helpers

This module contains identity-column validation helpers used by dataset mutation operations.

Functions¶

`validate_identity_columns`(→ None)	Ensure identity columns exist in both input and target table.
`validate_duplicate_identity_rows`(→ None)	Ensure input does not contain duplicate identity values.

Module Contents¶

ds_provider_postgresql_py_lib.utils.dataset_identity.validate_identity_columns(table: sqlalchemy.Table, identity_columns: collections.abc.Sequence[str], content: pandas.DataFrame) → None[source]¶

Ensure identity columns exist in both input and target table.

Parameters:

table – Reflected SQLAlchemy table.
identity_columns – Identity columns used for matching.
content – Input DataFrame.

Returns:

None

Raises:

ValidationError – If identity configuration is invalid.

ds_provider_postgresql_py_lib.utils.dataset_identity.validate_duplicate_identity_rows(content: pandas.DataFrame, identity_columns: collections.abc.Sequence[str]) → None[source]¶

Ensure input does not contain duplicate identity values.

Parameters:

content – Input DataFrame.
identity_columns – Identity columns used for matching.

Returns:

None

Raises:

ValidationError – If duplicate identity rows are found.