Skip to content
Snippets Groups Projects
Commit d38562e2 authored by Mads M. Pedersen's avatar Mads M. Pedersen
Browse files

merge functions da2py and coords2py

parent 1f33b135
No related branches found
No related tags found
No related merge requests found
...@@ -4,7 +4,7 @@ from py_wake.site.shear import PowerShear ...@@ -4,7 +4,7 @@ from py_wake.site.shear import PowerShear
import py_wake.utils.xarray_utils # register ilk function @UnusedImport import py_wake.utils.xarray_utils # register ilk function @UnusedImport
import xarray as xr import xarray as xr
from abc import ABC, abstractmethod from abc import ABC, abstractmethod
from py_wake.utils.xarray_utils import da2py, coords2py from py_wake.utils.xarray_utils import da2py
""" """
suffixs: suffixs:
...@@ -49,9 +49,9 @@ class LocalWind(xr.Dataset): ...@@ -49,9 +49,9 @@ class LocalWind(xr.Dataset):
for k, v in [('x', x_i), ('y', y_i), ('h', h_i)]: for k, v in [('x', x_i), ('y', y_i), ('h', h_i)]:
if v is not None: if v is not None:
coords[k] = ('i', np.zeros(n_i) + v) coords[k] = ('i', np.zeros(n_i) + v)
xr.Dataset.__init__(self, data_vars={k: da2py(v) for k, v in [('WD', WD), ('WS', WS), xr.Dataset.__init__(self, data_vars={k: da2py(v, include_dims=True) for k, v in [('WD', WD), ('WS', WS),
('TI', TI), ('P', P)] if v is not None}, ('TI', TI), ('P', P)] if v is not None},
coords={k: coords2py(v) for k, v in coords.items()}) coords={k: da2py(v) for k, v in coords.items()})
self.attrs['wd_bin_size'] = wd_bin_size self.attrs['wd_bin_size'] = wd_bin_size
# set localWind.WS_ilk etc. # set localWind.WS_ilk etc.
......
...@@ -130,16 +130,12 @@ if not hasattr(xr.DataArray(None), 'ilk'): ...@@ -130,16 +130,12 @@ if not hasattr(xr.DataArray(None), 'ilk'):
xr.register_dataarray_accessor('plot')(plot_xy_map) xr.register_dataarray_accessor('plot')(plot_xy_map)
def da2py(v, include_dims=True): def da2py(v, include_dims=False):
if isinstance(v, tuple):
return tuple([da2py(v, include_dims) for v in v])
if isinstance(v, DataArray): if isinstance(v, DataArray):
if include_dims: if include_dims:
return (v.dims, v.values) return (v.dims, v.values)
else: else:
return v.values return v.values
return v return v
def coords2py(v):
if isinstance(v, tuple):
return tuple([da2py(v, False) for v in v])
return v
...@@ -60,8 +60,8 @@ class WindFarmModel(ABC): ...@@ -60,8 +60,8 @@ class WindFarmModel(ABC):
if len(x) == 0: if len(x) == 0:
lw = UniformSite([1], 0.1).local_wind(x_i=[], y_i=[], h_i=[], wd=wd, ws=ws) lw = UniformSite([1], 0.1).local_wind(x_i=[], y_i=[], h_i=[], wd=wd, ws=ws)
z = xr.DataArray(np.zeros((0, len(lw.wd), len(lw.ws))), coords=[('wt', []), ('wd', da2py(lw.wd, False)), z = xr.DataArray(np.zeros((0, len(lw.wd), len(lw.ws))), coords=[('wt', []), ('wd', da2py(lw.wd)),
('ws', da2py(lw.ws, False))]) ('ws', da2py(lw.ws))])
return SimulationResult(self, lw, [], yaw, tilt, z, z, z, z, kwargs) return SimulationResult(self, lw, [], yaw, tilt, z, z, z, z, kwargs)
res = self.calc_wt_interaction(x_i=np.asarray(x), y_i=np.asarray(y), h_i=h, type_i=type, res = self.calc_wt_interaction(x_i=np.asarray(x), y_i=np.asarray(y), h_i=h, type_i=type,
yaw_ilk=yaw_ilk, tilt_ilk=tilt_ilk, yaw_ilk=yaw_ilk, tilt_ilk=tilt_ilk,
...@@ -170,7 +170,7 @@ class SimulationResult(xr.Dataset): ...@@ -170,7 +170,7 @@ class SimulationResult(xr.Dataset):
ilk_dims = (['wt', 'wd', 'ws'], ['wt', 'time'])['time' in lw] ilk_dims = (['wt', 'wd', 'ws'], ['wt', 'time'])['time' in lw]
xr.Dataset.__init__(self, xr.Dataset.__init__(self,
data_vars={k: (ilk_dims, da2py((v, v[:, :, 0])['time' in lw], include_dims=False), data_vars={k: (ilk_dims, da2py((v, v[:, :, 0])['time' in lw]),
{'Description': d}) {'Description': d})
for k, v, d in [('WS_eff', WS_eff_ilk, 'Effective local wind speed [m/s]'), for k, v, d in [('WS_eff', WS_eff_ilk, 'Effective local wind speed [m/s]'),
('TI_eff', np.zeros_like(WS_eff_ilk) + TI_eff_ilk, ('TI_eff', np.zeros_like(WS_eff_ilk) + TI_eff_ilk,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment