Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

formatting logging

Browse Source
This commit is contained in:
Matthias Bisping 2022-02-24 07:59:15 +01:00
parent 55ca5ced73
commit 328943e6f5
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pyinfra/storage/adapters/azure.py
View File

@ -37,7 +37,7 @@ class AzureStorageAdapter(StorageAdapter):
return container_client if container_client.exists() else self.__client.create_container(container_name) return container_client if container_client.exists() else self.__client.create_container(container_name)
def put(self, bucket_name, object_name, data): def put(self, bucket_name, object_name, data):
logger.debug(f"Uploading {object_name}") logger.debug(f"Uploading '{object_name}'...")
container_client = self.__provide_container_client(bucket_name) container_client = self.__provide_container_client(bucket_name)
blob_client = container_client.get_blob_client(object_name) blob_client = container_client.get_blob_client(object_name)
blob_client.upload_blob(data, overwrite=True) blob_client.upload_blob(data, overwrite=True)
@ -53,7 +53,7 @@ class AzureStorageAdapter(StorageAdapter):
container_client = self.__provide_container_client(bucket_name) container_client = self.__provide_container_client(bucket_name)
blobs = container_client.list_blobs(bucket_name) blobs = container_client.list_blobs(bucket_name)
for blob in blobs: for blob in blobs:
logger.debug(f"Downlaoding {blob.name}") logger.debug(f"Downlaoding '{blob.name}'...")
blob_client = container_client.get_blob_client(blob) blob_client = container_client.get_blob_client(blob)
blob_data = blob_client.download_blob() blob_data = blob_client.download_blob()
data = blob_data.readall() data = blob_data.readall()
@ -61,7 +61,7 @@ class AzureStorageAdapter(StorageAdapter):
@_retry(ResourceExistsError) @_retry(ResourceExistsError)
def purge(self, bucket_name): def purge(self, bucket_name):
logger.debug(f"Purging Azure container '{bucket_name}'") logger.debug(f"Purging Azure container '{bucket_name}'...")
container_client = self.__client.get_container_client(bucket_name) container_client = self.__client.get_container_client(bucket_name)
blobs = container_client.list_blobs() blobs = container_client.list_blobs()
container_client.delete_blobs(*blobs) container_client.delete_blobs(*blobs)