Skip to content

Commit dd9bfd2

Browse files
Calling dask.compute() at end of XInterpolation
1 parent 587bc6e commit dd9bfd2

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

parcels/application_kernels/interpolation.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44

55
from typing import TYPE_CHECKING
66

7+
import dask.array as dask
78
import numpy as np
89
import xarray as xr
910

@@ -102,7 +103,10 @@ def XLinear(
102103
else:
103104
F = F[:, 0, :]
104105

105-
return (1 - xsi) * (1 - eta) * F[:, 0] + xsi * (1 - eta) * F[:, 1] + (1 - xsi) * eta * F[:, 2] + xsi * eta * F[:, 3]
106+
value = (
107+
(1 - xsi) * (1 - eta) * F[:, 0] + xsi * (1 - eta) * F[:, 1] + (1 - xsi) * eta * F[:, 2] + xsi * eta * F[:, 3]
108+
)
109+
return value.compute() if isinstance(value, dask.Array) else value
106110

107111

108112
def UXPiecewiseConstantFace(

0 commit comments

Comments
 (0)