Skip to content

Commit b77d29f

Browse files
committed
Fix swallowing of cancel error in Formula Engine & Voltage streamer
Signed-off-by: Mathias L. Baumann <[email protected]>
1 parent 3b945dd commit b77d29f

File tree

2 files changed

+4
-6
lines changed

2 files changed

+4
-6
lines changed

src/frequenz/sdk/timeseries/_voltage_streamer.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -190,6 +190,5 @@ async def _send_request(self) -> None:
190190
"Phase-to-neutral 3-phase voltage streaming task cancelled: %s",
191191
self._source_component,
192192
)
193-
break
194-
else:
195-
await sender.send(msg)
193+
raise
194+
await sender.send(msg)

src/frequenz/sdk/timeseries/formula_engine/_formula_engine.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -584,9 +584,8 @@ async def _run(self) -> None:
584584
)
585585
except asyncio.CancelledError:
586586
_logger.debug("FormulaEngine task cancelled: %s", self._name)
587-
break
588-
else:
589-
await sender.send(msg)
587+
raise
588+
await sender.send(msg)
590589

591590
def new_receiver(
592591
self, name: str | None = None, max_size: int = 50

0 commit comments

Comments
 (0)