Peter Lim
02/29/2024, 1:07 AMScout
02/29/2024, 1:07 AMbuild_asset_reconciliation_sensor
. This sensor automatically materializes assets that have never been materialized or whose upstream assets have changed since the last time they were materialized. It works with partitioned assets as well. Additionally, you can add a FreshnessPolicy
to your software-defined assets to specify how up-to-date you expect that asset to be. You can then use the @freshness_policy_sensor
to alert when assets are missing their targets and to kick off runs to materialize assets based on their freshness policies. For more granular control, you can define custom sensors with the @multi_asset_sensor
decorator that trigger based on the materializations of multiple assets. This allows you to monitor the state of more than one asset and trigger runs accordingly. If you want to automate the process of materializing stale assets, you can use schedules, sensors, or auto-materialization policies to trigger each asset. These can be configured to materialize data only when it is necessary, such as when upstream data or code changes. For specific code examples and further details on how to implement these features, you should refer to the Dagster documentation on asset sensors, freshness policies, and asset reconciliation sensors.Peter Lim
02/29/2024, 1:10 AMScout
02/29/2024, 1:10 AM