Skip to content

Commit f97bf9b

Browse files
authored
TST Address dask delayed changes (#851)
1 parent 1e91ff7 commit f97bf9b

3 files changed

Lines changed: 4 additions & 4 deletions

File tree

rioxarray/raster_array.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1139,7 +1139,7 @@ def to_raster(
11391139
11401140
Returns
11411141
-------
1142-
:obj:`dask.Delayed`:
1142+
:obj:`dask.Delayed` | :obj:`dask.Array` | None:
11431143
If the data array is a dask array and compute
11441144
is True. Otherwise None is returned.
11451145

rioxarray/raster_dataset.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -504,7 +504,7 @@ def to_raster(
504504
505505
Returns
506506
-------
507-
:obj:`dask.Delayed`:
507+
:obj:`dask.Delayed` | :obj:`dask.Array` | None:
508508
If the data array is a dask array and compute
509509
is True. Otherwise None is returned.
510510

test/integration/test_integration_rioxarray.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1647,7 +1647,7 @@ def test_to_raster(
16471647
if write_lock is None or not isinstance(xds.data, dask.array.Array) or compute:
16481648
assert delayed is None
16491649
else:
1650-
assert isinstance(delayed, Delayed)
1650+
assert isinstance(delayed, (Delayed, dask.array.Array))
16511651
delayed.compute()
16521652

16531653
with rasterio.open(str(tmp_raster)) as rds:
@@ -1701,7 +1701,7 @@ def test_to_raster_3d(open_method, windowed, write_lock, compute, tmpdir):
17011701
if write_lock is None or not isinstance(xds.data, dask.array.Array) or compute:
17021702
assert delayed is None
17031703
else:
1704-
assert isinstance(delayed, Delayed)
1704+
assert isinstance(delayed, (Delayed, dask.array.Array))
17051705
delayed.compute()
17061706

17071707
with rasterio.open(str(tmp_raster)) as rds:

0 commit comments

Comments
 (0)