wiring.get_error_rows_key()

Return the default error-rows key of an asset.

Usage

Source

wiring.get_error_rows_key(asset_key)

It takes no override, because an override is a dg.AssetKey to pass as it is.

Parameters

asset_key: dg.AssetKey

The key of the asset whose rows fail validation.

Returns

dg.AssetKey

asset_key with __error_rows added to its last part. The key prefix stays.

Examples

import dagster as dg

import dagster_dataframely as dd

dd.wiring.get_error_rows_key(dg.AssetKey(["sales", "orders"]))

AssetKey(['sales', 'orders__error_rows'])