Add a creation_time attribute to Proposals

This is used to identify proposals that are too old, so that they can
be removed from consideration when the PowerManager calculates target
power.

Signed-off-by: Sahas Subramanian <[email protected]>

Author: shsms

src/frequenz/sdk/actor/_power_managing/_base_classes.py

@@ -207,6 +207,12 @@ class Proposal:
     priority: int
     """The priority of the actor sending the proposal."""
 
+    creation_time: float
+    """The loop time when the proposal is created.
+
+    This is used by the power manager to determine the age of the proposal.
+    """
+
     request_timeout: datetime.timedelta = datetime.timedelta(seconds=5.0)
     """The maximum amount of time to wait for the request to be fulfilled."""
 

src/frequenz/sdk/timeseries/battery_pool/_battery_pool.py

@@ -132,6 +132,7 @@ async def propose_power(
                 bounds=bounds,
                 component_ids=self._battery_pool._batteries,
                 priority=self._priority,
+                creation_time=asyncio.get_running_loop().time(),
                 request_timeout=request_timeout,
             )
         )
@@ -177,6 +178,7 @@ async def propose_charge(
                 bounds=timeseries.Bounds(None, None),
                 component_ids=self._battery_pool._batteries,
                 priority=self._priority,
+                creation_time=asyncio.get_running_loop().time(),
                 request_timeout=request_timeout,
             )
         )
@@ -222,6 +224,7 @@ async def propose_discharge(
                 bounds=timeseries.Bounds(None, None),
                 component_ids=self._battery_pool._batteries,
                 priority=self._priority,
+                creation_time=asyncio.get_running_loop().time(),
                 request_timeout=request_timeout,
             )
         )

tests/actor/_power_managing/test_matryoshka.py

@@ -3,6 +3,7 @@
 
 """Tests for the Matryoshka power manager algorithm."""
 
+import asyncio
 from datetime import datetime, timezone
 
 from frequenz.sdk import timeseries
@@ -46,6 +47,7 @@ def tgt_power(  # pylint: disable=too-many-arguments
                     None if bounds[1] is None else Power.from_watts(bounds[1]),
                 ),
                 priority=priority,
+                creation_time=asyncio.get_event_loop().time(),
             ),
             self._system_bounds,
             must_send,