Merge dask-specific kwargs with arbitrary from_array_kwargs dict. Temporary function, to be deleted once explicitly passing dask-specific kwargs to .chunk() is deprecated.
(
from_array_kwargs: dict[Any, Any],
name: str | None = None,
lock: bool | None = None,
inline_array: bool | None = None,
)
| 1269 | |
| 1270 | |
| 1271 | def consolidate_dask_from_array_kwargs( |
| 1272 | from_array_kwargs: dict[Any, Any], |
| 1273 | name: str | None = None, |
| 1274 | lock: bool | None = None, |
| 1275 | inline_array: bool | None = None, |
| 1276 | ) -> dict[Any, Any]: |
| 1277 | """ |
| 1278 | Merge dask-specific kwargs with arbitrary from_array_kwargs dict. |
| 1279 | |
| 1280 | Temporary function, to be deleted once explicitly passing dask-specific kwargs to .chunk() is deprecated. |
| 1281 | """ |
| 1282 | |
| 1283 | from_array_kwargs = _resolve_doubly_passed_kwarg( |
| 1284 | from_array_kwargs, |
| 1285 | kwarg_name="name", |
| 1286 | passed_kwarg_value=name, |
| 1287 | default=None, |
| 1288 | err_msg_dict_name="from_array_kwargs", |
| 1289 | ) |
| 1290 | from_array_kwargs = _resolve_doubly_passed_kwarg( |
| 1291 | from_array_kwargs, |
| 1292 | kwarg_name="lock", |
| 1293 | passed_kwarg_value=lock, |
| 1294 | default=False, |
| 1295 | err_msg_dict_name="from_array_kwargs", |
| 1296 | ) |
| 1297 | from_array_kwargs = _resolve_doubly_passed_kwarg( |
| 1298 | from_array_kwargs, |
| 1299 | kwarg_name="inline_array", |
| 1300 | passed_kwarg_value=inline_array, |
| 1301 | default=False, |
| 1302 | err_msg_dict_name="from_array_kwargs", |
| 1303 | ) |
| 1304 | |
| 1305 | return from_array_kwargs |
| 1306 | |
| 1307 | |
| 1308 | def _resolve_doubly_passed_kwarg( |
no test coverage detected
searching dependent graphs…