tabsdatak.conn.snowflake

AccountSpec
CredentialsSpec	The credential type for Snowflake connections: UserPassword (user + password / PAT).
DestCfgKey
DestCfgSpec
IdentifierSpec
IfTableExistsSpec
MergeCfg	How if_table_exists="merge" matches incoming rows onto a target table.
MergeCfgSpec	One MergeCfg per entry in SnowflakeDest.tables, in the same order.
MergeColumnSpec
MergeColumnsSpec
NameSpec
SchemaEvolutionEngineSpec	Which machinery evolves the target's schema.
SchemaEvolutionSpec
SnowflakeColumnSpec
SnowflakeDest	Snowflake destination for @subscriber -- one output slot per table.
SnowflakeDestConn	Snowflake account connection.
SnowflakeTableNameSpec
SnowflakeTableNamesSpec

---

AccountSpec

type_alias

AccountSpec: StrOrSecretSpec

Resolved type:

str | Secret

---

CredentialsSpec

type_alias

CredentialsSpec: UserPassword

The credential type for Snowflake connections: UserPassword (user + password / PAT).

---

DestCfgKey

type_alias

DestCfgKey: Literal['snowflake.logging_level', 'snowflake.schema_evolution_engine']

---

DestCfgSpec

type_alias

DestCfgSpec: Mapping[DestCfgKey, Any]

Resolved type:

Mapping[Literal['snowflake.logging_level', 'snowflake.schema_evolution_engine'], Any]

---

IdentifierSpec

type_alias

IdentifierSpec: StrOrSecretSpec

Resolved type:

str | Secret

---

IfTableExistsSpec

type_alias

IfTableExistsSpec: Literal['append', 'replace', 'merge']

---

MergeCfgSpec

type_alias

MergeCfgSpec: list[MergeCfg]

One MergeCfg per entry in SnowflakeDest.tables, in the same order.

A list even for a single table, so that reading a merge config off a destination never depends on how many tables it happens to write.

---

MergeColumnSpec

type_alias

MergeColumnSpec: SnowflakeColumnSpec

Resolved type:

str

---

MergeColumnsSpec

type_alias

MergeColumnsSpec: list[SnowflakeColumnSpec]

Resolved type:

list[str]

---

NameSpec

type_alias

NameSpec: IdentifierSpec

Resolved type:

str | Secret

---

SchemaEvolutionEngineSpec

type_alias

SchemaEvolutionEngineSpec: Literal['native', 'iceberg']

Which machinery evolves the target's schema. "native" leans on Snowflake's own ENABLE_SCHEMA_EVOLUTION, which COPY INTO honours; "iceberg" has the connector diff the target against the incoming file and emit the ALTER statements itself.

---

SchemaEvolutionSpec

type_alias

SchemaEvolutionSpec: Literal['update', 'strict']

---

SnowflakeColumnSpec

type_alias

SnowflakeColumnSpec: str

---

SnowflakeTableNameSpec

type_alias

SnowflakeTableNameSpec: str

---

SnowflakeTableNamesSpec

type_alias

SnowflakeTableNamesSpec: list[SnowflakeTableNameSpec]

Resolved type:

list[str]