MCPcopy Index your code
hub / github.com/pydata/xarray / consolidate_dask_from_array_kwargs

Function consolidate_dask_from_array_kwargs

xarray/core/utils.py:1271–1305  ·  view source on GitHub ↗

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,
)

Source from the content-addressed store, hash-verified

1269
1270
1271def 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
1308def _resolve_doubly_passed_kwarg(

Callers 1

chunkMethod · 0.90

Calls 1

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…