diff --git a/api/extensions/ext_storage.py b/api/extensions/ext_storage.py index db47760ef73c75..f22a15f225252c 100644 --- a/api/extensions/ext_storage.py +++ b/api/extensions/ext_storage.py @@ -45,14 +45,10 @@ def get_storage_factory(storage_type: str) -> Callable[[], BaseStorage]: # For R2 if "endpoint" in kwargs and "r2.cloudflarestorage.com" in kwargs["endpoint"]: - kwargs["disable_stat_with_override"] = True + kwargs["disable_stat_with_override"] = "true" kwargs["region"] = kwargs["region"] or "auto" logger.debug("Using R2 for S3") - for k, v in kwargs.items(): - if v is None: - logger.warning(f"S3 config {k} is not set") - return lambda: OpenDALStorage(scheme=OpenDALScheme.S3, **kwargs) case StorageType.AZURE_BLOB: from extensions.storage.azure_blob_storage import AzureBlobStorage