Implement lazy subscription for Coalesce function - #1322

Merged

shsms merged 26 commits into

frequenz-floss:v1.x.xfrom

shsms:lazy-coalesce

Dec 16, 2025

Commits on Dec 15, 2025

Use keyword-only arguments for AST node dataclasses
shsms
committed
c1a4668
Extract Node base class to separate module
shsms
committed
a7dc25c
Update functions to fetch their own arguments
shsms
committed
5e320a9
Propagate Sample types through AST evaluation
shsms
committed
97510c7
Make AST `evaluate` methods async
shsms
committed
f888367
Allow `TelemetryStream` AST nodes to subscribe to data on demand
shsms
committed
2075ad3
Return `Sample` after dividing QuantityT by `float`
shsms
committed
a37a75a
Add subscribe method to AST nodes for stream initialization
shsms
committed
187cf0e
Enable resend_latest on resampled stream channels
shsms
committed
720748b
add NodeSynchronizer for coordinating AST node evaluation
shsms
committed
c376dec
Use NodeSynchronizer for concurrent node evaluation
shsms
committed
93e5f33
Update formula tests to not expect channels to be created in order
shsms
committed
95c61ec
Add an unsubscribe method to AST nodes
shsms
committed
d272263
Handle missing timestamps gracefully in formula evaluator
shsms
committed
7c2cf3c
Update NodeSynchronizer to support syncing to the first node
shsms
committed
298df08
move FunCall class from _ast to _functions module
shsms
committed
631e5d2
Implement lazy subscription for Coalesce function
shsms
committed
a06702b
Remove commented-out code in formula evaluator
shsms
committed
3131305
Remove unused telemetry stream tracking in formula evaluator
shsms
committed
04bc40b
remove unused graph traversal methods
shsms
committed
a08a925
Remove unused types-networkx from dev-mypy dependencies
shsms
committed
5b1a7cf
Remove unnecessary pylint exception in ComponentGraph instantiation
shsms
committed
1ce6bcf
Improve formula syntax docs for `from_string` method
shsms
committed
bb9423c
Make `metric_fetcher` a required argument for `TelemetryStream`
shsms
committed
71b3215
Add docstrings for class attributes in AST nodes
shsms
committed
1cf3d4b

Commits on Dec 16, 2025

Apply suggestions from review comments
shsms
committed
9b02348

Navigation Menu

Uh oh!

Implement lazy subscription for Coalesce function - #1322

Implement lazy subscription for Coalesce function#1322
shsms merged 26 commits into
frequenz-floss:v1.x.xfrom
shsms:lazy-coalesce

Commits on Dec 15, 2025

Use keyword-only arguments for AST node dataclasses

Extract Node base class to separate module

Update functions to fetch their own arguments

Propagate Sample types through AST evaluation

Make AST `evaluate` methods async

Allow `TelemetryStream` AST nodes to subscribe to data on demand

Return `Sample` after dividing QuantityT by `float`

Add subscribe method to AST nodes for stream initialization

Enable resend_latest on resampled stream channels

add NodeSynchronizer for coordinating AST node evaluation

Use NodeSynchronizer for concurrent node evaluation

Update formula tests to not expect channels to be created in order

Add an unsubscribe method to AST nodes

Handle missing timestamps gracefully in formula evaluator

Update NodeSynchronizer to support syncing to the first node

move FunCall class from _ast to _functions module

Implement lazy subscription for Coalesce function

Remove commented-out code in formula evaluator

Remove unused telemetry stream tracking in formula evaluator

remove unused graph traversal methods

Remove unused types-networkx from dev-mypy dependencies

Remove unnecessary pylint exception in ComponentGraph instantiation

Improve formula syntax docs for `from_string` method

Make `metric_fetcher` a required argument for `TelemetryStream`

Add docstrings for class attributes in AST nodes

Commits on Dec 16, 2025

Apply suggestions from review comments