{"action":"opened","issue":{"url":"https://api.github.com/repos/pangeo-data/pangeo/issues/265","repository_url":"https://api.github.com/repos/pangeo-data/pangeo","labels_url":"https://api.github.com/repos/pangeo-data/pangeo/issues/265/labels{/name}","comments_url":"https://api.github.com/repos/pangeo-data/pangeo/issues/265/comments","events_url":"https://api.github.com/repos/pangeo-data/pangeo/issues/265/events","html_url":"https://github.com/pangeo-data/pangeo/issues/265","id":324550290,"number":265,"title":"zarr reads on the client don't work on latest cluster -- killed worker","user":{"login":"rabernat","id":1197350,"avatar_url":"https://avatars1.githubusercontent.com/u/1197350?v=4","gravatar_id":"","url":"https://api.github.com/users/rabernat","html_url":"https://github.com/rabernat","followers_url":"https://api.github.com/users/rabernat/followers","following_url":"https://api.github.com/users/rabernat/following{/other_user}","gists_url":"https://api.github.com/users/rabernat/gists{/gist_id}","starred_url":"https://api.github.com/users/rabernat/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/rabernat/subscriptions","organizations_url":"https://api.github.com/users/rabernat/orgs","repos_url":"https://api.github.com/users/rabernat/repos","events_url":"https://api.github.com/users/rabernat/events{/privacy}","received_events_url":"https://api.github.com/users/rabernat/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2018-05-18T20:58:57Z","updated_at":"2018-05-18T20:58:57Z","closed_at":null,"author_association":"CONTRIBUTOR","body":"When I go to actually load data from any of the zarr gcs datasets, I get an error like this\r\n\r\n```\r\n---------------------------------------------------------------------------\r\nKilledWorker                              Traceback (most recent call last)\r\n<ipython-input-6-0247f79e60da> in <module>()\r\n      1 plt.rcParams['figure.figsize'] = (15, 8)\r\n----> 2 ds.sla.sel(time='1982-08-07', method='nearest').plot()\r\n\r\n/opt/conda/lib/python3.6/site-packages/xarray/plot/plot.py in __call__(self, **kwargs)\r\n    372 \r\n    373     def __call__(self, **kwargs):\r\n--> 374         return plot(self._da, **kwargs)\r\n    375 \r\n    376     @functools.wraps(hist)\r\n\r\n/opt/conda/lib/python3.6/site-packages/xarray/plot/plot.py in plot(darray, row, col, col_wrap, ax, rtol, subplot_kws, **kwargs)\r\n    155     kwargs['ax'] = ax\r\n    156 \r\n--> 157     return plotfunc(darray, **kwargs)\r\n    158 \r\n    159 \r\n\r\n/opt/conda/lib/python3.6/site-packages/xarray/plot/plot.py in newplotfunc(darray, x, y, figsize, size, aspect, ax, row, col, col_wrap, xincrease, yincrease, add_colorbar, add_labels, vmin, vmax, cmap, center, robust, extend, levels, infer_intervals, colors, subplot_kws, cbar_ax, cbar_kwargs, **kwargs)\r\n    607 \r\n    608         # Pass the data as a masked ndarray too\r\n--> 609         zval = darray.to_masked_array(copy=False)\r\n    610 \r\n    611         _ensure_plottable(xval, yval)\r\n\r\n/opt/conda/lib/python3.6/site-packages/xarray/core/dataarray.py in to_masked_array(self, copy)\r\n   1453             Masked where invalid values (nan or inf) occur.\r\n   1454         \"\"\"\r\n-> 1455         isnull = pd.isnull(self.values)\r\n   1456         return np.ma.MaskedArray(data=self.values, mask=isnull, copy=copy)\r\n   1457 \r\n\r\n/opt/conda/lib/python3.6/site-packages/xarray/core/dataarray.py in values(self)\r\n    402     def values(self):\r\n    403         \"\"\"The array's data as a numpy.ndarray\"\"\"\r\n--> 404         return self.variable.values\r\n    405 \r\n    406     @values.setter\r\n\r\n/opt/conda/lib/python3.6/site-packages/xarray/core/variable.py in values(self)\r\n    385     def values(self):\r\n    386         \"\"\"The variable's data as a numpy.ndarray\"\"\"\r\n--> 387         return _as_array_or_item(self._data)\r\n    388 \r\n    389     @values.setter\r\n\r\n/opt/conda/lib/python3.6/site-packages/xarray/core/variable.py in _as_array_or_item(data)\r\n    209     TODO: remove this (replace with np.asarray) once these issues are fixed\r\n    210     \"\"\"\r\n--> 211     data = np.asarray(data)\r\n    212     if data.ndim == 0:\r\n    213         if data.dtype.kind == 'M':\r\n\r\n/opt/conda/lib/python3.6/site-packages/numpy/core/numeric.py in asarray(a, dtype, order)\r\n    490 \r\n    491     \"\"\"\r\n--> 492     return array(a, dtype, copy=False, order=order)\r\n    493 \r\n    494 \r\n\r\n/opt/conda/lib/python3.6/site-packages/dask/array/core.py in __array__(self, dtype, **kwargs)\r\n   1190 \r\n   1191     def __array__(self, dtype=None, **kwargs):\r\n-> 1192         x = self.compute()\r\n   1193         if dtype and x.dtype != dtype:\r\n   1194             x = x.astype(dtype)\r\n\r\n/opt/conda/lib/python3.6/site-packages/dask/base.py in compute(self, **kwargs)\r\n    152         dask.base.compute\r\n    153         \"\"\"\r\n--> 154         (result,) = compute(self, traverse=False, **kwargs)\r\n    155         return result\r\n    156 \r\n\r\n/opt/conda/lib/python3.6/site-packages/dask/base.py in compute(*args, **kwargs)\r\n    405     keys = [x.__dask_keys__() for x in collections]\r\n    406     postcomputes = [x.__dask_postcompute__() for x in collections]\r\n--> 407     results = get(dsk, keys, **kwargs)\r\n    408     return repack([f(r, *a) for r, (f, a) in zip(results, postcomputes)])\r\n    409 \r\n\r\n/opt/conda/lib/python3.6/site-packages/distributed/client.py in get(self, dsk, keys, restrictions, loose_restrictions, resources, sync, asynchronous, direct, retries, priority, fifo_timeout, **kwargs)\r\n   2096             try:\r\n   2097                 results = self.gather(packed, asynchronous=asynchronous,\r\n-> 2098                                       direct=direct)\r\n   2099             finally:\r\n   2100                 for f in futures.values():\r\n\r\n/opt/conda/lib/python3.6/site-packages/distributed/client.py in gather(self, futures, errors, maxsize, direct, asynchronous)\r\n   1506             return self.sync(self._gather, futures, errors=errors,\r\n   1507                              direct=direct, local_worker=local_worker,\r\n-> 1508                              asynchronous=asynchronous)\r\n   1509 \r\n   1510     @gen.coroutine\r\n\r\n/opt/conda/lib/python3.6/site-packages/distributed/client.py in sync(self, func, *args, **kwargs)\r\n    613             return future\r\n    614         else:\r\n--> 615             return sync(self.loop, func, *args, **kwargs)\r\n    616 \r\n    617     def __repr__(self):\r\n\r\n/opt/conda/lib/python3.6/site-packages/distributed/utils.py in sync(loop, func, *args, **kwargs)\r\n    251             e.wait(10)\r\n    252     if error[0]:\r\n--> 253         six.reraise(*error[0])\r\n    254     else:\r\n    255         return result[0]\r\n\r\n/opt/conda/lib/python3.6/site-packages/six.py in reraise(tp, value, tb)\r\n    691             if value.__traceback__ is not tb:\r\n    692                 raise value.with_traceback(tb)\r\n--> 693             raise value\r\n    694         finally:\r\n    695             value = None\r\n\r\n/opt/conda/lib/python3.6/site-packages/distributed/utils.py in f()\r\n    236             yield gen.moment\r\n    237             thread_state.asynchronous = True\r\n--> 238             result[0] = yield make_coro()\r\n    239         except Exception as exc:\r\n    240             error[0] = sys.exc_info()\r\n\r\n/opt/conda/lib/python3.6/site-packages/tornado/gen.py in run(self)\r\n   1097 \r\n   1098                     try:\r\n-> 1099                         value = future.result()\r\n   1100                     except Exception:\r\n   1101                         self.had_exception = True\r\n\r\n/opt/conda/lib/python3.6/site-packages/tornado/gen.py in run(self)\r\n   1105                     if exc_info is not None:\r\n   1106                         try:\r\n-> 1107                             yielded = self.gen.throw(*exc_info)\r\n   1108                         finally:\r\n   1109                             # Break up a reference to itself\r\n\r\n/opt/conda/lib/python3.6/site-packages/distributed/client.py in _gather(self, futures, errors, direct, local_worker)\r\n   1383                             six.reraise(type(exception),\r\n   1384                                         exception,\r\n-> 1385                                         traceback)\r\n   1386                     if errors == 'skip':\r\n   1387                         bad_keys.add(key)\r\n\r\n/opt/conda/lib/python3.6/site-packages/six.py in reraise(tp, value, tb)\r\n    691             if value.__traceback__ is not tb:\r\n    692                 raise value.with_traceback(tb)\r\n--> 693             raise value\r\n    694         finally:\r\n    695             value = None\r\n\r\nKilledWorker: ('zarr-30761e7bf266279b7254c29da310d0bd', 'tcp://10.20.144.7:43398')\r\n```\r\n\r\n😭 "}}
{"actor":{"display_login":"rabernat"}}