Skip to content

Commit 6a78e50

Browse files
committed
Make metric_fetcher a required argument for TelemetryStream
Signed-off-by: Sahas Subramanian <[email protected]>
1 parent 77b3541 commit 6a78e50

File tree

1 file changed

+1
-9
lines changed
  • src/frequenz/sdk/timeseries/formulas

1 file changed

+1
-9
lines changed

src/frequenz/sdk/timeseries/formulas/_ast.py

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -31,19 +31,11 @@ class TelemetryStream(AstNode[QuantityT]):
3131
[], Coroutine[None, None, Receiver[Sample[QuantityT] | Sample[Quantity]]]
3232
]
3333
| None
34-
) = None
34+
)
3535
create_method: Callable[[float], QuantityT]
3636
_stream: Receiver[Sample[QuantityT] | Sample[Quantity]] | None = None
3737
_latest_sample: Sample[QuantityT] | None = None
3838

39-
def __post_init__(self) -> None:
40-
"""Validate at least one of stream or metric_fetcher is set."""
41-
if self._stream is None and self.metric_fetcher is None:
42-
raise ValueError(
43-
"Either stream or metric_fetcher must be provided for "
44-
+ "TelemetryStream node."
45-
)
46-
4739
@property
4840
def latest_sample(self) -> Sample[QuantityT] | None:
4941
"""Return the latest fetched sample for this component."""

0 commit comments

Comments
 (0)