get_asset_key_from_dataset_name

kedro_dagster.utils.get_asset_key_from_dataset_name(dataset_name, env)

Get a Dagster AssetKey from a Kedro dataset name and environment.

Parameters

Name	Type	Description	Default
dataset_name	str	Kedro dataset name.	required
env	str	Kedro environment.	required

Returns

Type	Description
AssetKey	Corresponding Dagster AssetKey.

Source Code

View on GitHub

Show/Hide source

def get_asset_key_from_dataset_name(dataset_name: str, env: str) -> dg.AssetKey:
    """Get a Dagster AssetKey from a Kedro dataset name and environment.

    Parameters
    ----------
    dataset_name : str
        Kedro dataset name.
    env : str
        Kedro environment.

    Returns
    -------
    AssetKey
        Corresponding Dagster AssetKey.
    """
    return dg.AssetKey([env] + dataset_name.split("."))