refactor(assets): Operational lifetime

missing operational lifetime, considering it always operational

Signed-off-by: eduardiazf <[email protected]>

Author: eduardiazf

src/frequenz/client/assets/cli/__main__.py

@@ -274,14 +274,8 @@ async def list_microgrid_electrical_component_connections(
         component_connections = (
             await client.list_microgrid_electrical_component_connections(
                 microgrid_id,
-                source_component_ids=(
-                    list(source_component_ids) if source_component_ids else None
-                ),
-                destination_component_ids=(
-                    list(destination_component_ids)
-                    if destination_component_ids
-                    else None
-                ),
+                source_component_ids=source_component_ids,
+                destination_component_ids=destination_component_ids,
             )
         )
         print_component_connections(component_connections)

src/frequenz/client/assets/electrical_component/_connection.py

@@ -51,7 +51,7 @@ class ComponentConnection:
     This is the component towards which the current flows.
     """
 
-    operational_lifetime: Lifetime = dataclasses.field(default_factory=Lifetime)
+    operational_lifetime: Lifetime | None = None
     """The operational lifetime of the connection."""
 
     def __post_init__(self) -> None:
@@ -61,6 +61,8 @@ def __post_init__(self) -> None:
 
     def is_operational_at(self, timestamp: datetime) -> bool:
         """Check whether this connection is operational at a specific timestamp."""
+        if self.operational_lifetime is None:
+            return True
         return self.operational_lifetime.is_operational_at(timestamp)
 
     def is_operational_now(self) -> bool:

src/frequenz/client/assets/electrical_component/_connection_proto.py

@@ -25,7 +25,7 @@ def component_connection_from_proto(
     minor_issues: list[str] = []
 
     connection = component_connection_from_proto_with_issues(
-        message, major_issues=major_issues, minor_issues=minor_issues
+        message, major_issues=major_issues
     )
 
     if major_issues:
@@ -48,7 +48,6 @@ def component_connection_from_proto_with_issues(
     message: electrical_components_pb2.ElectricalComponentConnection,
     *,
     major_issues: list[str],
-    minor_issues: list[str],
 ) -> ComponentConnection | None:
     """Create a `ComponentConnection` from a protobuf message collecting issues.
 
@@ -58,7 +57,6 @@ def component_connection_from_proto_with_issues(
     Args:
         message: The protobuf message to parse.
         major_issues: A list to collect major issues found during parsing.
-        minor_issues: A list to collect minor issues found during parsing.
 
     Returns:
         A `ComponentConnection` object created from the protobuf message, or
@@ -73,9 +71,11 @@ def component_connection_from_proto_with_issues(
         )
         return None
 
-    lifetime = _get_operational_lifetime_from_proto(
-        message, major_issues=major_issues, minor_issues=minor_issues
-    )
+    try:
+        lifetime = _get_operational_lifetime_from_proto(message)
+    except ValueError as exc:
+        major_issues.append(f"connection ignored: invalid operational lifetime ({exc})")
+        return None
 
     return ComponentConnection(
         source=source_component_id,
@@ -86,21 +86,8 @@ def component_connection_from_proto_with_issues(
 
 def _get_operational_lifetime_from_proto(
     message: electrical_components_pb2.ElectricalComponentConnection,
-    *,
-    major_issues: list[str],
-    minor_issues: list[str],
-) -> Lifetime:
+) -> Lifetime | None:
     """Get the operational lifetime from a protobuf message."""
     if message.HasField("operational_lifetime"):
-        try:
-            return lifetime_from_proto(message.operational_lifetime)
-        except ValueError as exc:
-            major_issues.append(
-                f"invalid operational lifetime ({exc}), considering it as missing "
-                "(i.e. always operational)",
-            )
-    else:
-        minor_issues.append(
-            "missing operational lifetime, considering it always operational",
-        )
-    return Lifetime()
+        return lifetime_from_proto(message.operational_lifetime)
+    return None