@@ -120,7 +120,7 @@ def get_default_result_storage() -> WritableFileSystem:
120
120
return _default_storages [cache_key ]
121
121
122
122
if default_block is not None :
123
- storage = resolve_result_storage (default_block )
123
+ storage = resolve_result_storage (default_block , _sync = True )
124
124
if TYPE_CHECKING :
125
125
assert isinstance (storage , WritableFileSystem )
126
126
else :
@@ -184,7 +184,7 @@ def resolve_result_storage(
184
184
elif isinstance (result_storage , Path ):
185
185
storage_block = LocalFileSystem (basepath = str (result_storage ))
186
186
elif isinstance (result_storage , str ):
187
- block = Block .load (result_storage )
187
+ block = Block .load (result_storage , _sync = True )
188
188
if TYPE_CHECKING :
189
189
assert isinstance (block , WritableFileSystem )
190
190
storage_block = block
@@ -489,8 +489,6 @@ async def _exists(self, key: str) -> bool:
489
489
except Exception :
490
490
return False
491
491
else :
492
- if self .result_storage is None :
493
- self .result_storage = await aget_default_result_storage ()
494
492
try :
495
493
content = await _call_explicitly_async_block_method (
496
494
self .result_storage , "read_path" , (key ,), {}
@@ -972,8 +970,7 @@ async def store_parameters(self, identifier: UUID, parameters: dict[str, Any]):
972
970
serializer = self .serializer , storage_key = str (identifier )
973
971
),
974
972
)
975
- if self .result_storage is None :
976
- self .result_storage = await aget_default_result_storage ()
973
+
977
974
await _call_explicitly_async_block_method (
978
975
self .result_storage ,
979
976
"write_path" ,
0 commit comments