issues: 327064908
This data as json
| id | node_id | number | title | user | state | locked | assignee | milestone | comments | created_at | updated_at | closed_at | author_association | active_lock_reason | draft | pull_request | body | reactions | performed_via_github_app | state_reason | repo | type |
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| 327064908 | MDU6SXNzdWUzMjcwNjQ5MDg= | 2190 | Parallel non-locked read using dask.Client crashes | 6404167 | closed | 0 | 5 | 2018-05-28T15:42:40Z | 2019-01-14T21:09:04Z | 2019-01-14T21:09:03Z | CONTRIBUTOR | I'm trying to parallelize my code using Dask. Using their ``` python import xarray as xr import dask.array as da from dask.distributed import Client from IPython import embed First generate a file with random numbersrng = da.random.RandomState() shape = (10, 10000) chunks = (10, 10) dims = ['y', 'z'] x = rng.standard_normal(shape, chunks=chunks) da = xr.DataArray(x, dims=dims, name='x') da.to_netcdf('test.nc') Open file without a lockclient = Client(processes=False) ds = xr.open_dataset('test.nc', chunks=dict(zip(dims, chunks)), lock=False) This will crash!print((ds['x'] * ds['x']).compute())
Output of
|
{
"url": "https://api.github.com/repos/pydata/xarray/issues/2190/reactions",
"total_count": 0,
"+1": 0,
"-1": 0,
"laugh": 0,
"hooray": 0,
"confused": 0,
"heart": 0,
"rocket": 0,
"eyes": 0
} |
completed | 13221727 | issue |