wiring.table_schema()

Return the schema as the dg.TableSchema that Dagster’s Columns tab shows.

Usage

Source

wiring.table_schema(schema)

Each column has its dtype, description, nullability, uniqueness and column constraints. Its tags come from dy.Column(metadata=...), with each value converted to a string. The primary key is a table constraint, so only unique=True marks a key column unique.

Returns

A table schema with the columns in the schema’s order.

Raises

ReservedColumnError

A column name is in the reserved dy_ namespace.

InvalidColumnNameError

A column name has a character Dagster does not allow in an asset check name.

CheckNameCollisionError

Two rules produce the same asset check name.