-
-
Notifications
You must be signed in to change notification settings - Fork 1.2k
Closed
Labels
plan to closeMay be closeable, needs more eyeballsMay be closeable, needs more eyeballs
Description
What is your issue?
When using xarray with dask.array as in the following example:
import numpy as np
import xarray as xr
import dask
ds_ = xr.Dataset()
ds_["test"] = ("dim_0",), dask.array.from_array(
[0, 1, np.nan, np.nan, np.nan], chunks=2
)
then the ffill method does not seem to propagate through the underlying chunks used by dask.array.
In the example above, this means that
ds_.ffill("dim_0").compute().test.values
gives
>>> array([ 0., 1., 1., 1., nan])
where
ds_.compute().ffill("dim_0").test.values
gives
>>> array([0., 1., 1., 1., 1., 1.])
Is it an expected behavior ?
Metadata
Metadata
Assignees
Labels
plan to closeMay be closeable, needs more eyeballsMay be closeable, needs more eyeballs