diff --git a/servc/svc/com/storage/delta.py b/servc/svc/com/storage/delta.py index c2c4f40..76647d6 100644 --- a/servc/svc/com/storage/delta.py +++ b/servc/svc/com/storage/delta.py @@ -37,7 +37,7 @@ def __init__(self, config: Config, table: LakeTable): else: self._location_prefix = os.path.join( str(catalog_properties_raw.get("warehouse")), - str(catalog_properties_raw.get("s3.access-key-id")), + str(catalog_properties_raw.get("delta-prefix") or catalog_properties_raw.get("s3.access-key-id")), ) self._storageOptions = { "AWS_ACCESS_KEY_ID": str(