Add a propose_power method to EVChargerPool

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

Author: shsms

src/frequenz/sdk/microgrid/_data_pipeline.py

@@ -202,6 +202,9 @@ def ev_charger_pool(
                 status_receiver=self._ev_power_wrapper.status_channel.new_receiver(
                     maxsize=1
                 ),
+                power_manager_requests_sender=(
+                    self._ev_power_wrapper.proposal_channel.new_sender()
+                ),
                 power_manager_bounds_subs_sender=(
                     self._ev_power_wrapper.bounds_subscription_channel.new_sender()
                 ),

src/frequenz/sdk/timeseries/ev_charger_pool/_ev_charger_pool.py

@@ -8,9 +8,11 @@
 import typing
 import uuid
 from collections import abc
+from datetime import timedelta
 
 from ..._internal._channels import ReceiverFetcher
 from ...actor import _power_managing
+from ...timeseries import Bounds
 from .._base_types import SystemBounds
 from .._quantities import Current, Power
 from ..formula_engine import FormulaEngine, FormulaEngine3Phase
@@ -66,6 +68,66 @@ def __init__(  # pylint: disable=too-many-arguments
         self._source_id = unique_id if name is None else f"{name}-{unique_id}"
         self._priority = priority
 
+    async def propose_power(
+        self,
+        power: Power | None,
+        *,
+        request_timeout: timedelta = timedelta(seconds=5.0),
+        bounds: Bounds[Power | None] = Bounds(None, None),
+    ) -> None:
+        """Send a proposal to the power manager for the pool's set of EV chargers.
+
+        This proposal is for the maximum power that can be set for the EV chargers in
+        the pool.  The actual consumption might be lower based on the number of phases
+        an EV is drawing power from, and its current state of charge.
+
+        Power values need to follow the Passive Sign Convention (PSC). That is, positive
+        values indicate charge power and negative values indicate discharge power.
+        Discharging from EV chargers is currently not supported.
+
+        If the same EV chargers are shared by multiple actors, the power manager will
+        consider the priority of the actors, the bounds they set, and their preferred
+        power, when calculating the target power for the EV chargers
+
+        The preferred power of lower priority actors will take precedence as long as
+        they respect the bounds set by higher priority actors.  If lower priority actors
+        request power values outside of the bounds set by higher priority actors, the
+        target power will be the closest value to the preferred power that is within the
+        bounds.
+
+        When there are no other actors trying to use the same EV chargers, the actor's
+        preferred power would be set as the target power, as long as it falls within the
+        system power bounds for the EV chargers.
+
+        The result of the request can be accessed using the receiver returned from the
+        [`power_status`][frequenz.sdk.timeseries.ev_charger_pool.EVChargerPool.power_status]
+        method, which also streams the bounds that an actor should comply with, based on
+        its priority.
+
+        Args:
+            power: The power to propose for the EV chargers in the pool.  If `None`,
+                this proposal will not have any effect on the target power, unless
+                bounds are specified.  If both are `None`, it is equivalent to not
+                having a proposal or withdrawing a previous one.
+            request_timeout: The timeout for the request.
+            bounds: The power bounds for the proposal.  These bounds will apply to
+                actors with a lower priority, and can be overridden by bounds from
+                actors with a higher priority.  If None, the power bounds will be set to
+                the maximum power of the batteries in the pool.  This is currently and
+                experimental feature.
+        """
+        await self._ev_charger_pool.power_manager_requests_sender.send(
+            _power_managing.Proposal(
+                source_id=self._source_id,
+                preferred_power=power,
+                bounds=bounds,
+                component_ids=self._ev_charger_pool.component_ids,
+                priority=self._priority,
+                creation_time=asyncio.get_running_loop().time(),
+                request_timeout=request_timeout,
+            )
+        )
+
     @property
     def component_ids(self) -> abc.Set[int]:
         """Return component IDs of all EV Chargers managed by this EVChargerPool.

src/frequenz/sdk/timeseries/ev_charger_pool/_ev_charger_pool_reference_store.py

@@ -11,7 +11,7 @@
 from frequenz.channels import Broadcast, Receiver, Sender
 
 from ...actor import ChannelRegistry, ComponentMetricRequest
-from ...actor._power_managing import ReportRequest
+from ...actor._power_managing._base_classes import Proposal, ReportRequest
 from ...actor.power_distributing import ComponentPoolStatus
 from ...microgrid import connection_manager
 from ...microgrid.component import ComponentCategory
@@ -38,6 +38,7 @@ def __init__(  # pylint: disable=too-many-arguments
         channel_registry: ChannelRegistry,
         resampler_subscription_sender: Sender[ComponentMetricRequest],
         status_receiver: Receiver[ComponentPoolStatus],
+        power_manager_requests_sender: Sender[Proposal],
         power_manager_bounds_subs_sender: Sender[ReportRequest],
         component_ids: abc.Set[int] | None = None,
     ):
@@ -50,6 +51,8 @@ def __init__(  # pylint: disable=too-many-arguments
                 resampling actor.
             status_receiver: A receiver that streams the status of the EV Chargers in
                 the pool.
+            power_manager_requests_sender: A Channel sender for sending power
+                requests to the power managing actor.
             power_manager_bounds_subs_sender: A Channel sender for sending power bounds
                 subscription requests to the power managing actor.
             component_ids: An optional list of component_ids belonging to this pool.  If
@@ -59,6 +62,7 @@ def __init__(  # pylint: disable=too-many-arguments
         self.channel_registry = channel_registry
         self.resampler_subscription_sender = resampler_subscription_sender
         self.status_receiver = status_receiver
+        self.power_manager_requests_sender = power_manager_requests_sender
         self.power_manager_bounds_subs_sender = power_manager_bounds_subs_sender
 
         if component_ids is not None: