Shane Keller
03/05/2024, 11:42 PMScout
03/05/2024, 11:42 PMpython from dagster import asset @asset def upstream_asset(): # Perform some computation return "upstream_data" @asset def downstream_asset(upstream_asset): # Use the output of upstream_asset as input return f"downstream_data based on {upstream_asset}"
In this example, downstream_asset
uses the output of upstream_asset
as its input. When downstream_asset
is computed, Dagster ensures that upstream_asset
has already been computed and uses its output as the input for downstream_asset
. This is how dependencies between assets are managed in Dagster, allowing for clear data lineage and dependency tracking.