Skip to content

DRDataRaft/ docs

dr_add_catalog()

Catalog callbacks receive descriptive run metadata after execution. Delivery is outside the data transaction; retryable failures retain run evidence.

Usage

dr_add_catalog(x, catalog, name = NULL)

Arguments

x: A dr_product() definition.
catalog: Function receiving run metadata, or catalog adapter.
name: Optional unique catalog name, generated when omitted.

Value

An updated product definition.

Examples

dr_product("orders") |>
  dr_add_catalog(function(metadata) invisible(metadata), name = "audit")

See also

dataraft.adapters::dr_catalog_openlineage(), dr_retry_catalogs()

Documentation source snapshot · View source at d9cb454 ↗
Code examples are documented source examples; they are not executed in this website build.