Replace uses Selected.value with Selected.message

This field was renamed in the channel release v1.0.0-rc1.

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

Author: shsms

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

@@ -195,7 +195,7 @@ async def _run(self) -> None:
             drop_old_proposals_timer,
         ):
             if selected_from(selected, self._proposals_receiver):
-                proposal = selected.value
+                proposal = selected.message
                 if proposal.component_ids not in self._bound_tracker_tasks:
                     self._add_bounds_tracker(proposal.component_ids)
 
@@ -214,7 +214,7 @@ async def _run(self) -> None:
                 await self._send_reports(proposal.component_ids)
 
             elif selected_from(selected, self._bounds_subscription_receiver):
-                sub = selected.value
+                sub = selected.message
                 component_ids = sub.component_ids
                 priority = sub.priority
 
@@ -239,7 +239,7 @@ async def _run(self) -> None:
                     power_distributing,
                 )
 
-                result = selected.value
+                result = selected.message
                 self._distribution_results[frozenset(result.request.component_ids)] = (
                     result
                 )

src/frequenz/sdk/actor/power_distributing/_component_status/_battery_status_tracker.py

@@ -277,13 +277,13 @@ async def _run(
                     new_status = None
 
                     if selected_from(selected, battery):
-                        self._handle_status_battery(selected.value)
+                        self._handle_status_battery(selected.message)
 
                     elif selected_from(selected, inverter):
-                        self._handle_status_inverter(selected.value)
+                        self._handle_status_inverter(selected.message)
 
                     elif selected_from(selected, set_power_result):
-                        self._handle_status_set_power_result(selected.value)
+                        self._handle_status_set_power_result(selected.message)
 
                     elif selected_from(selected, battery_timer):
                         if (

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

@@ -110,7 +110,7 @@ async def _run(self) -> None:
                 raise ValueError("Meter channel closed.")
 
             if selected_from(selected, bound_chan):
-                bound: ComponentCurrentLimit = selected.value
+                bound: ComponentCurrentLimit = selected.message
                 if (
                     bound.component_id in latest_bound
                     and latest_bound[bound.component_id] == bound

tests/actor/test_actor.py

@@ -141,13 +141,13 @@ async def _run(self) -> None:
         channel_2 = self._recv2
 
         async for selected in select(channel_1, channel_2):
-            print(f"{self} received message {selected.value!r}")
+            print(f"{self} received message {selected.message!r}")
             if selected_from(selected, channel_1):
                 print(f"{self} sending message received from channel_1")
-                await self._output.send(selected.value)
+                await self._output.send(selected.message)
             elif selected_from(selected, channel_2):
                 print(f"{self} sending message received from channel_2")
-                await self._output.send(selected.value)
+                await self._output.send(selected.message)
 
         print(f"{self} done (should not happen)")