diff --git a/src/ess/livedata/handlers/timeseries_handler.py b/src/ess/livedata/handlers/timeseries_handler.py index bb884269f..bc1a7bcfd 100644 --- a/src/ess/livedata/handlers/timeseries_handler.py +++ b/src/ess/livedata/handlers/timeseries_handler.py @@ -29,7 +29,7 @@ def accumulate(self, data: dict[Hashable, sc.DataArray]) -> None: def finalize(self) -> dict[str, sc.DataArray]: if self._data is None: raise ValueError("No data has been added") - return {'cumulative': self._data, 'current': self._data} + return {'cumulative': self._data} def clear(self) -> None: self._data = None diff --git a/tests/services/timeseries_test.py b/tests/services/timeseries_test.py index ae825695a..19c03531e 100644 --- a/tests/services/timeseries_test.py +++ b/tests/services/timeseries_test.py @@ -67,17 +67,15 @@ def test_updates_are_published_immediately( app.publish_log_message(source_name=source_name, time=1, value=1.5) service.step() - # Each workflow call returns two results, cumulative and current - assert len(sink.messages) == 2 - assert sink.messages[-2].value.values.sum() == 1.5 + # Each workflow call returns one result, cumulative + assert len(sink.messages) == 1 assert sink.messages[-1].value.values.sum() == 1.5 # No data -> no data published service.step() - assert len(sink.messages) == 2 + assert len(sink.messages) == 1 # Just a tiny bit later, but batcher does not delay processing this. app.publish_log_message(source_name=source_name, time=1.0001, value=0.5) service.step() - assert len(sink.messages) == 4 - assert sink.messages[-2].value.values.sum() == 2.0 + assert len(sink.messages) == 2 assert sink.messages[-1].value.values.sum() == 2.0