File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -427,10 +427,7 @@ async def _create_index_for_node(
427427 return tree
428428
429429
430- async def _maybe_create_default_indexes_async (
431- ds : Dataset , executor = None
432- ) -> Dataset :
433-
430+ async def _maybe_create_default_indexes_async (ds : Dataset , executor = None ) -> Dataset :
434431 import asyncio
435432
436433 to_index_names = [
Original file line number Diff line number Diff line change @@ -1931,9 +1931,7 @@ def open_datatree(
19311931 )
19321932
19331933 # Async parallel group discovery (25x faster than sync recursive)
1934- group_paths = zarr_sync (
1935- _iter_zarr_groups_async (zarr_group , parent = parent )
1936- )
1934+ group_paths = zarr_sync (_iter_zarr_groups_async (zarr_group , parent = parent ))
19371935
19381936 return zarr_sync (
19391937 self ._open_datatree_from_stores_async (
@@ -2040,9 +2038,7 @@ def _sync_open():
20402038 if path_group == parent :
20412039 group_store = zarr_group
20422040 else :
2043- rel_path = path_group .removeprefix (f"{ parent } /" ).removeprefix (
2044- "/"
2045- )
2041+ rel_path = path_group .removeprefix (f"{ parent } /" ).removeprefix ("/" )
20462042 group_store = zarr_group [rel_path ]
20472043
20482044 store = ZarrStore (
@@ -2209,6 +2205,7 @@ async def open_groups_as_dict_async(
22092205 executor = ThreadPoolExecutor (
22102206 max_workers = max_workers , thread_name_prefix = "xarray"
22112207 )
2208+
22122209 async def open_one (path_group : str , store ) -> tuple [str , Dataset ]:
22132210 store_entrypoint = StoreBackendEntrypoint ()
22142211
You can’t perform that action at this time.
0 commit comments