Dagster - example showing how to pass the return data from an upstream asset to a downstream asset

example.py

from dagster import asset, Definitions, AssetExecutionContext

@asset
def upstream_asset():
    return "data produced by upstream_asset"

@asset()
def downstream_asset(context: AssetExecutionContext, upstream_asset: str):
    context.log.info(f"processed {upstream_asset}")
    return

defs = Definitions(
    assets=[upstream_asset, downstream_asset]
)