@@ -87,7 +87,9 @@ def __init__(self, credentials=None, **kwargs):
8787
8888 # Minio v7 uses keyword-only args for construction (endpoint=...).
8989 try :
90- self .minio = Minio (endpoint = end_point , access_key = access_key , secret_key = secret_key , secure = secure )
90+ self .minio = Minio (
91+ endpoint = end_point , access_key = access_key , secret_key = secret_key , secure = secure
92+ )
9193 except TypeError :
9294 # Fall back to positional args for older Minio versions.
9395 self .minio = Minio (end_point , access_key , secret_key , secure = secure )
@@ -196,7 +198,9 @@ async def async_read_blob(self, *, blob_name, pool, statistics, **kwargs):
196198 bucket , object_path , name , extension = paths .get_parts (blob_name )
197199 # DEBUG: print("READ ", name)
198200 stream = None
199- stream = self .minio .get_object (bucket_name = bucket , object_name = object_path + "/" + name + extension )
201+ stream = self .minio .get_object (
202+ bucket_name = bucket , object_name = object_path + "/" + name + extension
203+ )
200204 data = stream .read ()
201205
202206 ref = await pool .commit (data )
@@ -216,7 +220,9 @@ def read_blob(self, *, blob_name, **kwargs):
216220 stream = None
217221 try :
218222 bucket , object_path , name , extension = paths .get_parts (blob_name )
219- stream = self .minio .get_object (bucket_name = bucket , object_name = object_path + "/" + name + extension )
223+ stream = self .minio .get_object (
224+ bucket_name = bucket , object_name = object_path + "/" + name + extension
225+ )
220226 content = stream .read ()
221227 self .statistics .bytes_read += len (content )
222228 return content
0 commit comments