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 |