Skip to content
Snippets Groups Projects

Handle different start and end times of components

Merged Martin Lange requested to merge start-times into main
All threads resolved!
@@ -7,7 +7,7 @@ import xarray as xr
from finam.interfaces import ComponentStatus, Loggable
from ..data.tools import Info, assign_time
from ..data.tools import Info, strip_time
from ..errors import FinamNoDataError
from ..tools.log_helper import ErrorLogger
@@ -522,12 +522,9 @@ class ConnectHelper(Loggable):
def _push_data(self, name, data, time, info_time):
if info_time != time:
if isinstance(data, xr.DataArray):
data_1 = data if time is None else assign_time(data, time)
data_2 = (
copy.copy(data) if info_time is None else assign_time(data, time)
)
self.outputs[name].push_data(data_1, time)
self.outputs[name].push_data(data_2, info_time)
data_plain = strip_time(data)
self.outputs[name].push_data(data_plain, time)
self.outputs[name].push_data(copy.copy(data_plain), info_time)
else:
self.outputs[name].push_data(data, time)
self.outputs[name].push_data(copy.copy(data), info_time)
Loading