BC A
06/01/2023, 7:22 PMfrom dagster import AssetIn, dagster
########## empty asset
@asset(key_prefix = "PARENT_KEY_PREFIX", group_name="empty")
def empty(context):
return pd.DataFrame([])
@asset(
name = "asset_name",
key_prefix = "key_prefix",
required_resource_keys = {"custom_io_manager"},
io_manager_key = "custom_io_manager",
group_name = "outputs",
ins = {"upstream": AssetIn(key="empty", key_prefix="PARENT_KEY_PREFIX")}
)
def asset_def(context, upstream) -> None:
print("do stuff w/ asset")
return asset_def
claire
06/01/2023, 10:41 PMAssetIn(key=AssetKey(["PARENT_KEY_PREFIX", "empty"]))
BC A
06/06/2023, 11:01 AM