Implement lazy subscription for Coalesce function#1322

Merged

shsms merged 26 commits intofrequenz-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
Extract Node base class to separate module
shsms
committed
Update functions to fetch their own arguments
shsms
committed
Propagate Sample types through AST evaluation
shsms
committed
Make AST `evaluate` methods async
shsms
committed
Allow `TelemetryStream` AST nodes to subscribe to data on demand
shsms
committed
Return `Sample` after dividing QuantityT by `float`
shsms
committed
Add subscribe method to AST nodes for stream initialization
shsms
committed
Enable resend_latest on resampled stream channels
shsms
committed
add NodeSynchronizer for coordinating AST node evaluation
shsms
committed
Use NodeSynchronizer for concurrent node evaluation
shsms
committed
Update formula tests to not expect channels to be created in order
shsms
committed
Add an unsubscribe method to AST nodes
shsms
committed
Handle missing timestamps gracefully in formula evaluator
shsms
committed
Update NodeSynchronizer to support syncing to the first node
shsms
committed
move FunCall class from _ast to _functions module
shsms
committed
Implement lazy subscription for Coalesce function
shsms
committed
Remove commented-out code in formula evaluator
shsms
committed
Remove unused telemetry stream tracking in formula evaluator
shsms
committed
remove unused graph traversal methods
shsms
committed
Remove unused types-networkx from dev-mypy dependencies
shsms
committed
Remove unnecessary pylint exception in ComponentGraph instantiation
shsms
committed
Improve formula syntax docs for `from_string` method
shsms
committed
Make `metric_fetcher` a required argument for `TelemetryStream`
shsms
committed
Add docstrings for class attributes in AST nodes
shsms
committed

Commits on Dec 16, 2025

Apply suggestions from review comments
shsms
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Implement lazy subscription for Coalesce function#1322

Implement lazy subscription for Coalesce function#1322
shsms merged 26 commits intofrequenz-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

Implement lazy subscription for Coalesce function#1322shsms merged 26 commits intofrequenz-floss:v1.x.xfrequenz-floss/frequenz-sdk-python:v1.x.xfrom shsms:lazy-coalesceshsms/frequenz-sdk-python:lazy-coalesceCopy head branch name to clipboard

Commits

Commits on Dec 15, 2025

Commits on Dec 16, 2025

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