Called by open_dataset
(
self,
chunks: T_Chunks | _NormalizedChunks,
shape: tuple[int, ...] | None = None,
limit: int | None = None,
dtype: _DType_co | None = None,
previous_chunks: _NormalizedChunks | None = None,
)
| 44 | return data.chunks # type: ignore[no-any-return] |
| 45 | |
| 46 | def normalize_chunks( |
| 47 | self, |
| 48 | chunks: T_Chunks | _NormalizedChunks, |
| 49 | shape: tuple[int, ...] | None = None, |
| 50 | limit: int | None = None, |
| 51 | dtype: _DType_co | None = None, |
| 52 | previous_chunks: _NormalizedChunks | None = None, |
| 53 | ) -> Any: |
| 54 | """Called by open_dataset""" |
| 55 | from dask.array.core import normalize_chunks |
| 56 | |
| 57 | return normalize_chunks( |
| 58 | chunks, |
| 59 | shape=shape, |
| 60 | limit=limit, |
| 61 | dtype=dtype, |
| 62 | previous_chunks=previous_chunks, |
| 63 | ) # type: ignore[no-untyped-call] |
| 64 | |
| 65 | def from_array( |
| 66 | self, data: Any, chunks: T_Chunks | _NormalizedChunks, **kwargs: Any |