Skip to content

Commit f21b112

Browse files
Replace catching ReceiverError[Any] with just ReceiverError
It looks like ReceiverError[Any] is not ReceiverError, but some type object. When any error occured we got missleading error about the exception not inheriting from BaseException. Signed-off-by: Elzbieta Kotulska <[email protected]>
1 parent 91080f3 commit f21b112

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
import logging
99
import math
1010
from abc import ABC, abstractmethod
11-
from typing import Any, Generic
11+
from typing import Generic
1212

1313
from frequenz.channels import Receiver, ReceiverError, ReceiverStoppedError
1414

@@ -450,7 +450,7 @@ async def _fetch_from_fallback(
450450
self._name,
451451
)
452452
return None
453-
except ReceiverError[Any] as err:
453+
except ReceiverError as err:
454454
_logger.error(
455455
"Failed to fetch next value from fallback stream %s: %s",
456456
self._name,
@@ -527,7 +527,7 @@ async def _fetch_next(self) -> Sample[QuantityT] | None:
527527
"Failed to fetch next value from %s. Primary stream closed.",
528528
self._name,
529529
)
530-
except ReceiverError[Any] as err:
530+
except ReceiverError as err:
531531
_logger.error("Failed to fetch next value from %s: %s", self._name, err)
532532

533533
# We have no fallback, so we just return primary value even if it is not correct.

0 commit comments

Comments
 (0)