@@ -272,8 +272,8 @@ async def new_file(self, drive_name, path):
272272 path = path .strip ('/' )
273273
274274 # TO DO: switch to mode "created", which is not implemented yet
275- await obs .put_async (self ._content_managers [drive_name ], path , b"" , mode = "overwrite" )
276- metadata = await obs .head_async (self ._content_managers [drive_name ], path )
275+ await obs .put_async (self ._content_managers [drive_name ][ "store" ] , path , b"" , mode = "overwrite" )
276+ metadata = await obs .head_async (self ._content_managers [drive_name ][ "store" ] , path )
277277
278278 data = {
279279 "path" : path ,
@@ -329,8 +329,8 @@ async def save_file(self, drive_name, path, content, options_format, content_for
329329 else :
330330 formatted_content = content
331331
332- await obs .put_async (self ._content_managers [drive_name ], path , formatted_content , mode = "overwrite" )
333- metadata = await obs .head_async (self ._content_managers [drive_name ], path )
332+ await obs .put_async (self ._content_managers [drive_name ][ "store" ] , path , formatted_content , mode = "overwrite" )
333+ metadata = await obs .head_async (self ._content_managers [drive_name ][ "store" ] , path )
334334
335335 data = {
336336 "path" : path ,
@@ -362,8 +362,8 @@ async def rename_file(self, drive_name, path, new_path):
362362 # eliminate leading and trailing backslashes
363363 path = path .strip ('/' )
364364
365- await obs .rename_async (self ._content_managers [drive_name ], path , new_path )
366- metadata = await obs .head_async (self ._content_managers [drive_name ], new_path )
365+ await obs .rename_async (self ._content_managers [drive_name ][ "store" ] , path , new_path )
366+ metadata = await obs .head_async (self ._content_managers [drive_name ][ "store" ] , new_path )
367367
368368 data = {
369369 "path" : new_path ,
@@ -391,7 +391,7 @@ async def delete_file(self, drive_name, path):
391391 try :
392392 # eliminate leading and trailing backslashes
393393 path = path .strip ('/' )
394- await obs .delete_async (self ._content_managers [drive_name ], path )
394+ await obs .delete_async (self ._content_managers [drive_name ][ "store" ] , path )
395395
396396 except Exception as e :
397397 raise tornado .web .HTTPError (
@@ -411,7 +411,7 @@ async def check_file(self, drive_name, path):
411411 try :
412412 # eliminate leading and trailing backslashes
413413 path = path .strip ('/' )
414- await obs .head_async (self ._content_managers [drive_name ], path )
414+ await obs .head_async (self ._content_managers [drive_name ][ "store" ] , path )
415415 except Exception :
416416 raise tornado .web .HTTPError (
417417 status_code = httpx .codes .NOT_FOUND ,
@@ -433,8 +433,8 @@ async def copy_file(self, drive_name, path, to_path):
433433 # eliminate leading and trailing backslashes
434434 path = path .strip ('/' )
435435
436- await obs .copy_async (self ._content_managers [drive_name ], path , to_path )
437- metadata = await obs .head_async (self ._content_managers [drive_name ], to_path )
436+ await obs .copy_async (self ._content_managers [drive_name ][ "store" ] , path , to_path )
437+ metadata = await obs .head_async (self ._content_managers [drive_name ][ "store" ] , to_path )
438438
439439 data = {
440440 "path" : to_path ,
0 commit comments