469d93a7430bbb3e79140dfa31bd016b3b221c8a,mlflow/store/artifact/dbfs_artifact_repo.py,,dbfs_artifact_repo_factory,#Any#,159

Before Change

    cleaned_artifact_uri = artifact_uri.rstrip("/")
    uri_scheme = get_uri_scheme(artifact_uri)
    if uri_scheme != "dbfs":
        raise MlflowException("DBFS URI must be of the form "
                              "dbfs:/<path>, but received {uri}".format(uri=artifact_uri))
    if is_databricks_acled_artifacts_uri(artifact_uri):
        return DatabricksArtifactRepository(cleaned_artifact_uri)
    elif mlflow.utils.databricks_utils.is_dbfs_fuse_available() \
            and os.environ.get(USE_FUSE_ENV_VAR, "").lower() != "false" \

After Change

    :return: Subclass of ArtifactRepository capable of storing artifacts on DBFS.
    
    if not is_valid_dbfs_uri(artifact_uri):
        raise MlflowException("DBFS URI must be of the form dbfs:/<path> or " +
                              "dbfs://profile@databricks/<path>, but received " + artifact_uri)

    cleaned_artifact_uri = artifact_uri.rstrip("/")
    db_profile_uri = get_databricks_profile_uri_from_artifact_uri(cleaned_artifact_uri)
    if is_databricks_acled_artifacts_uri(artifact_uri):

Instances