Show More
| @@ -142,10 +142,13 b' class ObjectStoreCache(BaseCache):' | |||||
| 142 | endpoint_url = settings.pop('archive_cache.objectstore.url') |
|
142 | endpoint_url = settings.pop('archive_cache.objectstore.url') | |
| 143 | key = settings.pop('archive_cache.objectstore.key') |
|
143 | key = settings.pop('archive_cache.objectstore.key') | |
| 144 | secret = settings.pop('archive_cache.objectstore.secret') |
|
144 | secret = settings.pop('archive_cache.objectstore.secret') | |
|
|
145 | region = settings.pop('archive_cache.objectstore.region') | |||
| 145 |
|
146 | |||
| 146 | log.debug('Initializing %s archival cache instance', self) |
|
147 | log.debug('Initializing %s archival cache instance', self) | |
| 147 |
|
148 | |||
| 148 | fs = fsspec.filesystem('s3', anon=False, endpoint_url=endpoint_url, key=key, secret=secret) |
|
149 | fs = fsspec.filesystem( | |
|
|
150 | 's3', anon=False, endpoint_url=endpoint_url, key=key, secret=secret, client_kwargs={'region_name': region} | |||
|
|
151 | ) | |||
| 149 |
|
152 | |||
| 150 | # init main bucket |
|
153 | # init main bucket | |
| 151 | if not fs.exists(self._bucket): |
|
154 | if not fs.exists(self._bucket): | |
General Comments 0
You need to be logged in to leave comments.
Login now