Skip to content

Commit 0f5dc6a

Browse files
committed
Add missing PV and EV components to datapipeline's stop method
Signed-off-by: Sahas Subramanian <[email protected]>
1 parent ac4959e commit 0f5dc6a

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/frequenz/sdk/microgrid/_data_pipeline.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -495,8 +495,14 @@ async def _stop(self) -> None:
495495
if self._resampling_actor:
496496
await self._resampling_actor.actor.stop()
497497
await self._battery_power_wrapper.stop()
498+
await self._ev_power_wrapper.stop()
499+
await self._pv_power_wrapper.stop()
498500
for pool in self._battery_pool_reference_stores.values():
499501
await pool.stop()
502+
for evpool in self._ev_charger_pool_reference_stores.values():
503+
await evpool.stop()
504+
for pvpool in self._pv_pool_reference_stores.values():
505+
await pvpool.stop()
500506

501507

502508
_DATA_PIPELINE: _DataPipeline | None = None

0 commit comments

Comments
 (0)