wiring.quarantine_frame()

Return the invalid rows as a writer receives them, with one rule column per rule.

Usage

Source

wiring.quarantine_frame(
    schema,
    failure,
)

Returns

The original columns in their own order, then a String rule column for every rule, named by check_name. A rule column’s value is valid, invalid or unknown.

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.