Skip to content

kedro_dagster.utils

Utility functions.

Classes

Name Description
CliContext Runtime context passed to CLI command handlers.

Functions

Name Description
find_kedro_project Locate the Kedro project root starting from current_dir.
render_jinja_template Render a Jinja template from a file or string.
write_jinja_template Render and write a Jinja template to a destination file.
get_asset_key_from_dataset_name Get a Dagster AssetKey from a Kedro dataset name and environment.
is_nothing_asset_name Return True if the catalog entry is a DagsterNothingDataset.
get_dataset_from_catalog Retrieve a dataset instance from a Kedro catalog across versions.
get_match_pattern_from_catalog_resolver Return the matching dataset pattern from a CatalogConfigResolver.
get_partition_mapping Get the appropriate partition mapping for an asset based on its downstream datasets.
format_partition_key Format a partition key into a Dagster-safe suffix (^[A-Za-z0-9_]+$).
format_dataset_name Convert a dataset name so that it is valid under Dagster's naming convention.
format_node_name Convert a node name so that it is valid under Dagster's naming convention.
unformat_asset_name Convert a Dagster-formatted asset name back to Kedro's naming convention.
is_mlflow_enabled Check if MLflow is enabled in the Kedro context.
get_filter_params_dict Extract filter parameters from a pipeline config dict.
get_mlflow_resource_from_config Create a Dagster resource definition from MLflow config.
get_mlflow_run_url Return a fully functional MLflow UI URL for the currently active run.