Slackbot
09/12/2022, 2:31 PMsean
09/14/2022, 8:29 PMfrom dagster import AssetOut, asset, multi_asset, define_asset_job, repository
@asset
def foo():
return [1, 2, 3]
@multi_asset(
outs={
"user": AssetOut(),
"pwd": AssetOut(),
}
)
def credentials(foo):
# ...
return user, password
@asset
def bar(user):
return "bar"
@asset
def baz(pwd):
return "baz"
all_assets_job = define_asset_job(name="all_assets_job")
@repository
def repo():
return [
foo,
bar,
baz,
credentials,
all_assets_job
]
multi_asset