As Dagster doesn’t control scheduling or materializing external assets, it’s up to you to keep their metadata updated. The APIs in this reference can be used to keep external assets updated in Dagster.
External asset events can be recorded using DagsterInstance.report_runless_asset_event() on DagsterInstance.
Example: Reporting an asset materialization:
from dagster import DagsterInstance, AssetMaterialization, AssetKey
instance = DagsterInstance.get()
instance.report_runless_asset_event(AssetMaterialization(AssetKey("example_asset")))
Example: Reporting an asset check evaluation:
from dagster import DagsterInstance, AssetCheckEvaluation, AssetCheckKey
instance = DagsterInstance.get()
instance.report_runless_asset_event(
AssetCheckEvaluation(
asset_key=AssetKey("example_asset"),
check_name="example_check",
passed=True
)
)
Refer to the External assets REST API reference for information and examples on the available APIs.