Andreas Fred Ojala
11/17/2022, 12:39 PMfrom dagster import (
asset,
repository,
OpExecutionContext,
)
@asset
def upstream_asset():
return 1
@asset(config_schema={"test": int})
def downstream_asset(context: OpExecutionContext, upstream_asset):
return upstream_asset + context.op_config["test"]
@asset(config_schema={"input": int})
def standalone_asset():
return 0
@repository
def repo():
return [upstream_asset, downstream_asset, standalone_asset]
sandy
11/17/2022, 3:58 PMsean
11/17/2022, 4:01 PMDagster Bot
11/17/2022, 4:10 PMAndreas Fred Ojala
11/18/2022, 6:57 AM