Quentin Gaborit
08/31/2023, 8:10 AMdef get_asset_key(self, dbt_resource_props: Mapping[str, Any]) -> AssetKey:
"""Get the Dagster dbt asset key from the dbt schema.
:param dbt_resource_props: The dbt node JSON description.
:return: The key to use for the dbt asset.
"""
if dbt_resource_props["config"].get("alias"):
return AssetKey(dbt_resource_props["config"].get("alias"))
else:
return default_asset_key_fn(dbt_resource_props)
However, it seems that this would yield duplicate asset keys, which I don't understand since Dagster asset can be duplicated (at least python ones). Any way to bypass that error?sandy
08/31/2023, 1:48 PM