File tree Expand file tree Collapse file tree 9 files changed +18
-16
lines changed Expand file tree Collapse file tree 9 files changed +18
-16
lines changed Original file line number Diff line number Diff line change @@ -34,7 +34,7 @@ class SuffixRange(TypedDict):
3434 """The number of bytes from the suffix to request."""
3535
3636
37- ByteRangeRequest : TypeAlias = None | tuple [int , int ] | OffsetRange | SuffixRange
37+ ByteRangeRequest : TypeAlias = tuple [int , int ] | OffsetRange | SuffixRange
3838
3939
4040class Store (ABC ):
@@ -181,7 +181,7 @@ async def get(
181181 async def get_partial_values (
182182 self ,
183183 prototype : BufferPrototype ,
184- key_ranges : Iterable [tuple [str , ByteRangeRequest ]],
184+ key_ranges : Iterable [tuple [str , ByteRangeRequest | None ]],
185185 ) -> list [Buffer | None ]:
186186 """Retrieve possibly partial values from given key_ranges.
187187
Original file line number Diff line number Diff line change @@ -102,7 +102,7 @@ async def open(
102102 async def get (
103103 self ,
104104 prototype : BufferPrototype | None = None ,
105- byte_range : ByteRangeRequest = None ,
105+ byte_range : ByteRangeRequest | None = None ,
106106 ) -> Buffer | None :
107107 """
108108 Read bytes from the store.
Original file line number Diff line number Diff line change @@ -199,7 +199,7 @@ async def get(
199199 self ,
200200 key : str ,
201201 prototype : BufferPrototype ,
202- byte_range : ByteRangeRequest = None ,
202+ byte_range : ByteRangeRequest | None = None ,
203203 ) -> Buffer | None :
204204 # docstring inherited
205205 if not self ._is_open :
@@ -272,7 +272,7 @@ async def exists(self, key: str) -> bool:
272272 async def get_partial_values (
273273 self ,
274274 prototype : BufferPrototype ,
275- key_ranges : Iterable [tuple [str , ByteRangeRequest ]],
275+ key_ranges : Iterable [tuple [str , ByteRangeRequest | None ]],
276276 ) -> list [Buffer | None ]:
277277 # docstring inherited
278278 if key_ranges :
Original file line number Diff line number Diff line change 1818 from zarr .core .buffer import BufferPrototype
1919
2020
21- def _get (path : Path , prototype : BufferPrototype , byte_range : ByteRangeRequest ) -> Buffer :
21+ def _get (path : Path , prototype : BufferPrototype , byte_range : ByteRangeRequest | None ) -> Buffer :
2222 if byte_range is None :
2323 return prototype .buffer .from_bytes (path .read_bytes ())
2424 with path .open ("rb" ) as f :
@@ -122,7 +122,7 @@ async def get(
122122 self ,
123123 key : str ,
124124 prototype : BufferPrototype | None = None ,
125- byte_range : ByteRangeRequest = None ,
125+ byte_range : ByteRangeRequest | None = None ,
126126 ) -> Buffer | None :
127127 # docstring inherited
128128 if prototype is None :
@@ -140,7 +140,7 @@ async def get(
140140 async def get_partial_values (
141141 self ,
142142 prototype : BufferPrototype ,
143- key_ranges : Iterable [tuple [str , ByteRangeRequest ]],
143+ key_ranges : Iterable [tuple [str , ByteRangeRequest | None ]],
144144 ) -> list [Buffer | None ]:
145145 # docstring inherited
146146 args = []
Original file line number Diff line number Diff line change @@ -161,7 +161,7 @@ async def get(
161161 self ,
162162 key : str ,
163163 prototype : BufferPrototype ,
164- byte_range : ByteRangeRequest = None ,
164+ byte_range : ByteRangeRequest | None = None ,
165165 ) -> Buffer | None :
166166 # docstring inherited
167167 with self .log (key ):
@@ -170,7 +170,7 @@ async def get(
170170 async def get_partial_values (
171171 self ,
172172 prototype : BufferPrototype ,
173- key_ranges : Iterable [tuple [str , ByteRangeRequest ]],
173+ key_ranges : Iterable [tuple [str , ByteRangeRequest | None ]],
174174 ) -> list [Buffer | None ]:
175175 # docstring inherited
176176 keys = "," .join ([k [0 ] for k in key_ranges ])
Original file line number Diff line number Diff line change @@ -75,7 +75,7 @@ async def get(
7575 self ,
7676 key : str ,
7777 prototype : BufferPrototype ,
78- byte_range : ByteRangeRequest = None ,
78+ byte_range : ByteRangeRequest | None = None ,
7979 ) -> Buffer | None :
8080 # docstring inherited
8181 if not self ._is_open :
@@ -91,7 +91,7 @@ async def get(
9191 async def get_partial_values (
9292 self ,
9393 prototype : BufferPrototype ,
94- key_ranges : Iterable [tuple [str , ByteRangeRequest ]],
94+ key_ranges : Iterable [tuple [str , ByteRangeRequest | None ]],
9595 ) -> list [Buffer | None ]:
9696 # docstring inherited
9797
Original file line number Diff line number Diff line change @@ -45,7 +45,9 @@ def normalize_path(path: str | bytes | Path | None) -> str:
4545 return result
4646
4747
48- def _normalize_byte_range_index (data : Buffer , byte_range : ByteRangeRequest ) -> tuple [int , int ]:
48+ def _normalize_byte_range_index (
49+ data : Buffer , byte_range : ByteRangeRequest | None
50+ ) -> tuple [int , int ]:
4951 """
5052 Convert an ByteRangeRequest into an explicit start and stop
5153 """
Original file line number Diff line number Diff line change @@ -77,7 +77,7 @@ async def get(
7777 async def get_partial_values (
7878 self ,
7979 prototype : BufferPrototype ,
80- key_ranges : Iterable [tuple [str , ByteRangeRequest ]],
80+ key_ranges : Iterable [tuple [str , ByteRangeRequest | None ]],
8181 ) -> list [Buffer | None ]:
8282 return await self ._store .get_partial_values (prototype , key_ranges )
8383
Original file line number Diff line number Diff line change @@ -138,7 +138,7 @@ def _get(
138138 self ,
139139 key : str ,
140140 prototype : BufferPrototype ,
141- byte_range : ByteRangeRequest = None ,
141+ byte_range : ByteRangeRequest | None = None ,
142142 ) -> Buffer | None :
143143 # docstring inherited
144144 try :
@@ -178,7 +178,7 @@ async def get(
178178 async def get_partial_values (
179179 self ,
180180 prototype : BufferPrototype ,
181- key_ranges : Iterable [tuple [str , ByteRangeRequest ]],
181+ key_ranges : Iterable [tuple [str , ByteRangeRequest | None ]],
182182 ) -> list [Buffer | None ]:
183183 # docstring inherited
184184 out = []
You can’t perform that action at this time.
0 commit comments