wiring.delegating_writer()

Return a writer that passes the invalid rows to the asset’s own IO manager.

Usage

Source

wiring.delegating_writer(context)

The manager stores the rows under the asset key <name>_quarantine, as it stores any other asset: PolarsParquetIOManager writes a parquet file beside the table, and DuckDBPolarsIOManager writes a table beside it. The writer discards the metadata the manager emits for this write.

Parameters

context: dg.AssetExecutionContext

Its asset definition must have exactly one asset, as a @dg.asset does.

Returns

A writer that takes the invalid rows and returns the quarantine’s asset key as a string.

Raises

dagster._core.errors.DagsterInvalidPropertyError

There is no step, which means a direct invocation. Use file_writer there.