Update API dependency

* selector was renamed to target
* start_immediately was added in the proto rpc create

Signed-off-by: Mathias L. Baumann <[email protected]>

# Conflicts:
#	src/frequenz/client/dispatch/_client.py
#	src/frequenz/client/dispatch/_internal_types.py
#	src/frequenz/client/dispatch/types.py
#	tests/test_proto.py

Author: Marenz

pyproject.toml

@@ -37,7 +37,7 @@ classifiers = [
 requires-python = ">= 3.11, < 4"
 dependencies = [
   "typing-extensions >= 4.6.1, < 5",
-  "frequenz-api-dispatch >= 0.15.1, < 0.16",
+  "frequenz-api-dispatch == 1.0.0-rc1",
   "frequenz-client-base >= 0.7.0, < 0.8.0",
   "frequenz-client-common >= 0.1.0, < 0.3.0",
   "grpcio >= 1.66.1, < 2",
@@ -87,7 +87,7 @@ dev-pylint = [
   "pylint == 3.3.1",
   # For checking the noxfile, docs/ script, and tests
   "frequenz-client-dispatch[cli,dev-mkdocs,dev-noxfile,dev-pytest]",
-  "frequenz-api-dispatch >= 0.15.1, < 0.16",
+  "frequenz-api-dispatch == 1.0.0-rc1",
 ]
 dev-pytest = [
   "pytest == 8.3.3",

src/frequenz/client/dispatch/__main__.py

@@ -28,7 +28,7 @@
     FuzzyIntRange,
     FuzzyTimeDelta,
     JsonDictParamType,
-    SelectorParamType,
+    TargetComponentParamType,
 )
 from ._client import Client
 
@@ -79,7 +79,7 @@ async def cli(ctx: click.Context, url: str, key: str) -> None:
 @cli.command("list")
 @click.pass_context
 @click.argument("microgrid-id", required=True, type=int)
-@click.option("--selector", "-s", type=SelectorParamType(), multiple=True)
+@click.option("--target", "-t", type=TargetComponentParamType(), multiple=True)
 @click.option("--start-from", type=FuzzyDateTime())
 @click.option("--start-to", type=FuzzyDateTime())
 @click.option("--end-from", type=FuzzyDateTime())
@@ -92,11 +92,12 @@ async def list_(ctx: click.Context, /, **filters: Any) -> None:
 
     Lists all dispatches for MICROGRID_ID that match the given filters.
 
-    The selector option can be given multiple times.
+    The target option can be given multiple times.
     """
-    if "selector" in filters:
-        selector = filters.pop("selector")
-        filters["component_selectors"] = selector
+    if "target" in filters:
+        target = filters.pop("target")
+        # Name of the parameter in client.list()
+        filters["target_components"] = target
 
     num_dispatches = 0
     async for page in ctx.obj["client"].list(**filters):
@@ -241,7 +242,7 @@ def validate_reccurance(ctx: click.Context, param: click.Parameter, value: Any)
     required=True,
     type=str,
 )
-@click.argument("selector", required=True, type=SelectorParamType())
+@click.argument("target", required=True, type=TargetComponentParamType())
 @click.argument("start-time", required=True, type=FuzzyDateTime())
 @click.argument("duration", required=False, type=FuzzyTimeDelta())
 @click.option("--active", "-a", type=bool, default=True)
@@ -260,7 +261,7 @@ async def create(
     Creates a new dispatch for MICROGRID_ID of type TYPE running for DURATION seconds
     starting at START_TIME.
 
-    SELECTOR is a comma-separated list of either component categories or component IDs.
+    TARGET is a comma-separated list of either component categories or component IDs.
     Possible component categories: "BATTERY, GRID, METER, INVERTER, EV_CHARGER, CHP".
     """
     # Remove keys with `None` value
@@ -286,7 +287,7 @@ async def create(
 @click.option("--start-time", type=FuzzyDateTime())
 @click.option("--duration", type=FuzzyTimeDelta())
 @click.option("--no-duration", is_flag=True)
-@click.option("--selector", type=SelectorParamType())
+@click.option("--target", type=TargetComponentParamType())
 @click.option("--active", type=bool)
 @click.option(
     "--payload", "-p", type=JsonDictParamType(), help="JSON payload for the dispatch"

src/frequenz/client/dispatch/_cli_types.py

@@ -130,10 +130,10 @@ def convert(
             self.fail(f"Invalid integer range: {value}", param, ctx)
 
 
-class SelectorParamType(click.ParamType):
-    """Click parameter type for selectors."""
+class TargetComponentParamType(click.ParamType):
+    """Click parameter type for targets."""
 
-    name = "selector"
+    name = "target"
 
     def convert(
         self, value: Any, param: click.Parameter | None, ctx: click.Context | None
@@ -154,7 +154,7 @@ def convert(
         values = value.split(",")
 
         if len(values) == 0:
-            self.fail("Empty selector list", param, ctx)
+            self.fail("Empty target list", param, ctx)
 
         error: Exception | None = None
         # Attempt to parse component ids

src/frequenz/client/dispatch/_client.py

@@ -42,10 +42,10 @@
 from ._internal_types import DispatchCreateRequest
 from .recurrence import RecurrenceRule
 from .types import (
-    ComponentSelector,
     Dispatch,
     DispatchEvent,
-    _component_selector_to_protobuf,
+    TargetComponents,
+    _target_components_to_protobuf,
 )
 
 # pylint: enable=no-name-in-module
@@ -110,7 +110,7 @@ async def list(
         self,
         microgrid_id: int,
         *,
-        component_selectors: Iterator[ComponentSelector] = iter(()),
+        target_components: Iterator[TargetComponents] = iter(()),
         start_from: datetime | None = None,
         start_to: datetime | None = None,
         end_from: datetime | None = None,
@@ -136,7 +136,7 @@ async def list(
 
         Args:
             microgrid_id: The microgrid_id to list dispatches for.
-            component_selectors: optional, list of component ids or categories to filter by.
+            target_components: optional, list of component ids or categories to filter by.
             start_from: optional, filter by start_time >= start_from.
             start_to: optional, filter by start_time < start_to.
             end_from: optional, filter by end_time >= end_from.
@@ -166,9 +166,9 @@ def to_interval(
         # Setup parameters
         start_time_interval = to_interval(start_from, start_to)
         end_time_interval = to_interval(end_from, end_to)
-        selectors = list(map(_component_selector_to_protobuf, component_selectors))
+        targets = list(map(_target_components_to_protobuf, target_components))
         filters = DispatchFilter(
-            selectors=selectors,
+            targets=targets,
             start_time_interval=start_time_interval,
             end_time_interval=end_time_interval,
             is_active=active,
@@ -256,7 +256,7 @@ async def create(  # pylint: disable=too-many-positional-arguments
         type: str,  # pylint: disable=redefined-builtin
         start_time: datetime,
         duration: timedelta | None,
-        selector: ComponentSelector,
+        target: TargetComponents,
         *,
         active: bool = True,
         dry_run: bool = False,
@@ -271,7 +271,7 @@ async def create(  # pylint: disable=too-many-positional-arguments
             start_time: The start time of the dispatch.
             duration: The duration of the dispatch. Can be `None` for infinite
                 or no-duration dispatches (e.g. switching a component on).
-            selector: The component selector for the dispatch.
+            target: The component target for the dispatch.
             active: The active status of the dispatch.
             dry_run: The dry_run status of the dispatch.
             payload: The payload of the dispatch.
@@ -295,7 +295,7 @@ async def create(  # pylint: disable=too-many-positional-arguments
             type=type,
             start_time=start_time,
             duration=duration,
-            selector=selector,
+            target=target,
             active=active,
             dry_run=dry_run,
             payload=payload or {},
@@ -353,8 +353,8 @@ async def update(
                         msg.update.ClearField("duration")
                     else:
                         msg.update.duration = round(val.total_seconds())
-                case "selector":
-                    msg.update.selector.CopyFrom(_component_selector_to_protobuf(val))
+                case "target":
+                    msg.update.target.CopyFrom(_target_components_to_protobuf(val))
                 case "is_active":
                     msg.update.is_active = val
                 case "payload":

src/frequenz/client/dispatch/_internal_types.py

@@ -20,9 +20,9 @@
 
 from .recurrence import RecurrenceRule
 from .types import (
-    ComponentSelector,
-    _component_selector_from_protobuf,
-    _component_selector_to_protobuf,
+    TargetComponents,
+    _target_components_from_protobuf,
+    _target_components_to_protobuf,
 )
 
 # pylint: enable=no-name-in-module
@@ -51,8 +51,8 @@ class DispatchCreateRequest:
     like a command to turn on a component.
     """
 
-    selector: ComponentSelector
-    """The component selector specifying which components the dispatch targets."""
+    target: TargetComponents
+    """The target components of the dispatch."""
 
     active: bool
     """Indicates whether the dispatch is active and eligible for processing."""
@@ -69,7 +69,6 @@ class DispatchCreateRequest:
 
     recurrence: RecurrenceRule | None
     """The recurrence rule for the dispatch.
-
     Defining any repeating patterns or schedules."""
 
     @classmethod
@@ -97,9 +96,7 @@ def from_protobuf(
                 to_datetime(pb_object.dispatch_data.start_time)
             ),
             duration=duration,
-            selector=_component_selector_from_protobuf(
-                pb_object.dispatch_data.selector
-            ),
+            target=_target_components_from_protobuf(pb_object.dispatch_data.target),
             active=pb_object.dispatch_data.is_active,
             dry_run=pb_object.dispatch_data.is_dry_run,
             payload=MessageToDict(pb_object.dispatch_data.payload),
@@ -123,7 +120,7 @@ def to_protobuf(self) -> PBDispatchCreateRequest:
                 duration=(
                     round(self.duration.total_seconds()) if self.duration else None
                 ),
-                selector=_component_selector_to_protobuf(self.selector),
+                target=_target_components_to_protobuf(self.target),
                 is_active=self.active,
                 is_dry_run=self.dry_run,
                 payload=payload,

src/frequenz/client/dispatch/test/_service.py

@@ -176,8 +176,8 @@ def _filter_dispatch(
         """Filter a dispatch based on the request."""
         if request.HasField("filter"):
             _filter = request.filter
-            for selector in _filter.selectors:
-                if selector != dispatch.selector:
+            for target in _filter.targets:
+                if target != dispatch.target:
                     return False
             if _filter.HasField("start_time_interval"):
                 if start_from := _filter.start_time_interval.__dict__["from"]:
@@ -272,7 +272,7 @@ async def UpdateMicrogridDispatch(
                         getattr(request.update, split_path[0]),
                     )
                 # Fields that need to be copied
-                case "start_time" | "selector" | "payload":
+                case "start_time" | "target" | "payload":
                     getattr(pb_dispatch.data, split_path[0]).CopyFrom(
                         getattr(request.update, split_path[0])
                     )

src/frequenz/client/dispatch/test/client.py

@@ -82,7 +82,7 @@ def to_create_params(microgrid_id: int, dispatch: Dispatch) -> dict[str, Any]:
         "type": dispatch.type,
         "start_time": dispatch.start_time,
         "duration": dispatch.duration,
-        "selector": dispatch.selector,
+        "target": dispatch.target,
         "active": dispatch.active,
         "dry_run": dispatch.dry_run,
         "payload": dispatch.payload,

src/frequenz/client/dispatch/test/generator.py

@@ -92,7 +92,7 @@ def generate_dispatch(self) -> Dispatch:
                     timedelta(seconds=self._rng.randint(0, 1000000)),
                 ]
             ),
-            selector=self._rng.choice(  # type: ignore
+            target=self._rng.choice(  # type: ignore
                 [
                     [
                         self._rng.choice(list(ComponentCategory)[1:])