diff --git a/composer/utils/file_helpers.py b/composer/utils/file_helpers.py index 0b640806474..2a5c5005256 100644 --- a/composer/utils/file_helpers.py +++ b/composer/utils/file_helpers.py @@ -21,8 +21,8 @@ from composer.utils import dist from composer.utils.iter_helpers import iterate_with_callback from composer.utils.misc import partial_format -from composer.utils.object_store import (GCSObjectStore, MLFlowObjectStore, ObjectStore, OCIObjectStore, S3ObjectStore, - UCObjectStore, LibcloudObjectStore) +from composer.utils.object_store import (GCSObjectStore, LibcloudObjectStore, MLFlowObjectStore, ObjectStore, + OCIObjectStore, S3ObjectStore, UCObjectStore) from composer.utils.object_store.mlflow_object_store import MLFLOW_DBFS_PATH_PREFIX if TYPE_CHECKING: @@ -319,6 +319,7 @@ def parse_uri(uri: str) -> Tuple[str, str, str]: Tuple[str, str, str]: A tuple containing the backend (e.g. s3), bucket name, and path. Backend name will be empty string if the input is a local path """ + uri = uri.replace('AZURE_BLOBS', 'azure') # urlparse does not support _ in scheme parse_result = urlparse(uri) backend, net_loc, path = parse_result.scheme, parse_result.netloc, parse_result.path bucket_name = net_loc if '@' not in net_loc else net_loc.split('@')[0] @@ -357,8 +358,8 @@ def maybe_create_object_store_from_uri(uri: str) -> Optional[ObjectStore]: return OCIObjectStore(bucket=bucket_name) elif backend == 'azure': return LibcloudObjectStore( - provider='AZURE_BLOBS', - container=bucket_name, + provider='AZURE_BLOBS', + container=bucket_name, key_environ='AZURE_ACCOUNT_NAME', secret_environ='AZURE_ACCOUNT_ACCESS_KEY', )