@@ -57,11 +57,11 @@ def register(self, cls: type[T], qualname: str | None = None) -> None:
5757 self [qualname ] = cls
5858
5959
60- __codec_registries : dict [str , Registry [Codec ]] = defaultdict (Registry )
61- __pipeline_registry : Registry [CodecPipeline ] = Registry ()
62- __buffer_registry : Registry [Buffer ] = Registry ()
63- __ndbuffer_registry : Registry [NDBuffer ] = Registry ()
64- __chunk_key_encoding_registry : Registry [ChunkKeyEncoding ] = Registry ()
60+ _codec_registries : dict [str , Registry [Codec ]] = defaultdict (Registry )
61+ _pipeline_registry : Registry [CodecPipeline ] = Registry ()
62+ _buffer_registry : Registry [Buffer ] = Registry ()
63+ _ndbuffer_registry : Registry [NDBuffer ] = Registry ()
64+ _chunk_key_encoding_registry : Registry [ChunkKeyEncoding ] = Registry ()
6565
6666"""
6767The registry module is responsible for managing implementations of codecs,
@@ -93,37 +93,37 @@ def _collect_entrypoints() -> list[Registry[Any]]:
9393 """
9494 entry_points = get_entry_points ()
9595
96- __buffer_registry .lazy_load_list .extend (entry_points .select (group = "zarr.buffer" ))
97- __buffer_registry .lazy_load_list .extend (entry_points .select (group = "zarr" , name = "buffer" ))
98- __ndbuffer_registry .lazy_load_list .extend (entry_points .select (group = "zarr.ndbuffer" ))
99- __ndbuffer_registry .lazy_load_list .extend (entry_points .select (group = "zarr" , name = "ndbuffer" ))
96+ _buffer_registry .lazy_load_list .extend (entry_points .select (group = "zarr.buffer" ))
97+ _buffer_registry .lazy_load_list .extend (entry_points .select (group = "zarr" , name = "buffer" ))
98+ _ndbuffer_registry .lazy_load_list .extend (entry_points .select (group = "zarr.ndbuffer" ))
99+ _ndbuffer_registry .lazy_load_list .extend (entry_points .select (group = "zarr" , name = "ndbuffer" ))
100100
101101 data_type_registry ._lazy_load_list .extend (entry_points .select (group = "zarr.data_type" ))
102102 data_type_registry ._lazy_load_list .extend (entry_points .select (group = "zarr" , name = "data_type" ))
103103
104- __chunk_key_encoding_registry .lazy_load_list .extend (
104+ _chunk_key_encoding_registry .lazy_load_list .extend (
105105 entry_points .select (group = "zarr.chunk_key_encoding" )
106106 )
107- __chunk_key_encoding_registry .lazy_load_list .extend (
107+ _chunk_key_encoding_registry .lazy_load_list .extend (
108108 entry_points .select (group = "zarr" , name = "chunk_key_encoding" )
109109 )
110110
111- __pipeline_registry .lazy_load_list .extend (entry_points .select (group = "zarr.codec_pipeline" ))
112- __pipeline_registry .lazy_load_list .extend (
111+ _pipeline_registry .lazy_load_list .extend (entry_points .select (group = "zarr.codec_pipeline" ))
112+ _pipeline_registry .lazy_load_list .extend (
113113 entry_points .select (group = "zarr" , name = "codec_pipeline" )
114114 )
115115 for e in entry_points .select (group = "zarr.codecs" ):
116- __codec_registries [e .name ].lazy_load_list .append (e )
116+ _codec_registries [e .name ].lazy_load_list .append (e )
117117 for group in entry_points .groups :
118118 if group .startswith ("zarr.codecs." ):
119119 codec_name = group .split ("." )[2 ]
120- __codec_registries [codec_name ].lazy_load_list .extend (entry_points .select (group = group ))
120+ _codec_registries [codec_name ].lazy_load_list .extend (entry_points .select (group = group ))
121121 return [
122- * __codec_registries .values (),
123- __pipeline_registry ,
124- __buffer_registry ,
125- __ndbuffer_registry ,
126- __chunk_key_encoding_registry ,
122+ * _codec_registries .values (),
123+ _pipeline_registry ,
124+ _buffer_registry ,
125+ _ndbuffer_registry ,
126+ _chunk_key_encoding_registry ,
127127 ]
128128
129129
@@ -137,36 +137,36 @@ def fully_qualified_name(cls: type) -> str:
137137
138138
139139def register_codec (key : str , codec_cls : type [Codec ], * , qualname : str | None = None ) -> None :
140- if key not in __codec_registries :
141- __codec_registries [key ] = Registry ()
142- __codec_registries [key ].register (codec_cls , qualname = qualname )
140+ if key not in _codec_registries :
141+ _codec_registries [key ] = Registry ()
142+ _codec_registries [key ].register (codec_cls , qualname = qualname )
143143
144144
145145def register_pipeline (pipe_cls : type [CodecPipeline ]) -> None :
146- __pipeline_registry .register (pipe_cls )
146+ _pipeline_registry .register (pipe_cls )
147147
148148
149149def register_ndbuffer (cls : type [NDBuffer ], qualname : str | None = None ) -> None :
150- __ndbuffer_registry .register (cls , qualname )
150+ _ndbuffer_registry .register (cls , qualname )
151151
152152
153153def register_buffer (cls : type [Buffer ], qualname : str | None = None ) -> None :
154- __buffer_registry .register (cls , qualname )
154+ _buffer_registry .register (cls , qualname )
155155
156156
157157def register_chunk_key_encoding (key : str , cls : type ) -> None :
158- __chunk_key_encoding_registry .register (cls , key )
158+ _chunk_key_encoding_registry .register (cls , key )
159159
160160
161161def get_codec_class (key : str , reload_config : bool = False ) -> type [Codec ]:
162162 if reload_config :
163163 _reload_config ()
164164
165- if key in __codec_registries :
165+ if key in _codec_registries :
166166 # logger.debug("Auto loading codec '%s' from entrypoint", codec_id)
167- __codec_registries [key ].lazy_load ()
167+ _codec_registries [key ].lazy_load ()
168168
169- codec_classes = __codec_registries [key ]
169+ codec_classes = _codec_registries [key ]
170170 if not codec_classes :
171171 raise KeyError (key )
172172 config_entry = config .get ("codecs" , {}).get (key )
@@ -257,50 +257,50 @@ def _parse_array_array_codec(data: dict[str, JSON] | Codec) -> ArrayArrayCodec:
257257def get_pipeline_class (reload_config : bool = False ) -> type [CodecPipeline ]:
258258 if reload_config :
259259 _reload_config ()
260- __pipeline_registry .lazy_load ()
260+ _pipeline_registry .lazy_load ()
261261 path = config .get ("codec_pipeline.path" )
262- pipeline_class = __pipeline_registry .get (path )
262+ pipeline_class = _pipeline_registry .get (path )
263263 if pipeline_class :
264264 return pipeline_class
265265 raise BadConfigError (
266- f"Pipeline class '{ path } ' not found in registered pipelines: { list (__pipeline_registry )} ."
266+ f"Pipeline class '{ path } ' not found in registered pipelines: { list (_pipeline_registry )} ."
267267 )
268268
269269
270270def get_buffer_class (reload_config : bool = False ) -> type [Buffer ]:
271271 if reload_config :
272272 _reload_config ()
273- __buffer_registry .lazy_load ()
273+ _buffer_registry .lazy_load ()
274274
275275 path = config .get ("buffer" )
276- buffer_class = __buffer_registry .get (path )
276+ buffer_class = _buffer_registry .get (path )
277277 if buffer_class :
278278 return buffer_class
279279 raise BadConfigError (
280- f"Buffer class '{ path } ' not found in registered buffers: { list (__buffer_registry )} ."
280+ f"Buffer class '{ path } ' not found in registered buffers: { list (_buffer_registry )} ."
281281 )
282282
283283
284284def get_ndbuffer_class (reload_config : bool = False ) -> type [NDBuffer ]:
285285 if reload_config :
286286 _reload_config ()
287- __ndbuffer_registry .lazy_load ()
287+ _ndbuffer_registry .lazy_load ()
288288 path = config .get ("ndbuffer" )
289- ndbuffer_class = __ndbuffer_registry .get (path )
289+ ndbuffer_class = _ndbuffer_registry .get (path )
290290 if ndbuffer_class :
291291 return ndbuffer_class
292292 raise BadConfigError (
293- f"NDBuffer class '{ path } ' not found in registered buffers: { list (__ndbuffer_registry )} ."
293+ f"NDBuffer class '{ path } ' not found in registered buffers: { list (_ndbuffer_registry )} ."
294294 )
295295
296296
297297def get_chunk_key_encoding_class (key : str ) -> type [ChunkKeyEncoding ]:
298- __chunk_key_encoding_registry .lazy_load (use_entrypoint_name = True )
299- if key not in __chunk_key_encoding_registry :
298+ _chunk_key_encoding_registry .lazy_load (use_entrypoint_name = True )
299+ if key not in _chunk_key_encoding_registry :
300300 raise KeyError (
301- f"Chunk key encoding '{ key } ' not found in registered chunk key encodings: { list (__chunk_key_encoding_registry )} ."
301+ f"Chunk key encoding '{ key } ' not found in registered chunk key encodings: { list (_chunk_key_encoding_registry )} ."
302302 )
303- return __chunk_key_encoding_registry [key ]
303+ return _chunk_key_encoding_registry [key ]
304304
305305
306306_collect_entrypoints ()
0 commit comments