File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Load Diff This file was deleted.
Original file line number Diff line number Diff line change @@ -482,10 +482,8 @@ async def write(
482482 # event loop, it overrides these methods and sets supports_sync_io
483483 # to True. This lets Array selection methods bypass sync() entirely.
484484 #
485- # The default implementations raise NotImplementedError, so
486- # BatchedCodecPipeline (the standard pipeline) is unaffected.
487- #
488- # See docs/design/sync-bypass.md for the full design rationale.
485+ # The default implementations raise NotImplementedError.
486+ # BatchedCodecPipeline overrides these when all codecs support sync.
489487 # -------------------------------------------------------------------
490488
491489 @property
Original file line number Diff line number Diff line change 1414
1515from dataclasses import dataclass
1616
17- from zarr .core .codec_pipeline import (
18- BatchedCodecPipeline ,
19- _CODEC_DECODE_NS_PER_BYTE , # noqa: F401
20- _CODEC_ENCODE_NS_PER_BYTE , # noqa: F401
21- _choose_workers , # noqa: F401
22- _estimate_chunk_work_ns , # noqa: F401
23- )
17+ from zarr .core .codec_pipeline import BatchedCodecPipeline
2418from zarr .registry import register_pipeline
2519
2620__all__ = ["SyncCodecPipeline" ]
You can’t perform that action at this time.
0 commit comments