Hotfix lane reporting

Author: wasnertobias

logos/logos-workernode/logos_worker_node/lane_manager.py

@@ -602,6 +602,14 @@ async def get_lane_status(self, lane_id: str) -> LaneStatus:
         async with self._lock:
             return await self._get_status_unlocked(lane_id)
 
+    def get_current_lane_configs(self) -> list[LaneConfig]:
+        """Return the LaneConfig for every active lane (for state persistence)."""
+        configs: list[LaneConfig] = []
+        for handle in self._handles.values():
+            if handle.lane_config is not None:
+                configs.append(handle.lane_config)
+        return configs
+
     def get_handle(self, lane_id: str) -> ProcessHandle | None:
         return self._handles.get(lane_id)
 

logos/logos-workernode/logos_worker_node/logos_bridge.py

@@ -458,11 +458,19 @@ async def _execute_command(self, action: str, params: dict[str, Any]) -> dict[st
         if action == "add_lane":
             lane_config = LaneConfig(**params)
             status = await lane_manager.add_lane(lane_config)
+            try:
+                save_lanes_state(lane_manager.get_current_lane_configs())
+            except OSError:
+                logger.debug("Could not persist lane state after add_lane")
             return status.model_dump(mode="json")
 
         lane_id = str(params.get("lane_id", "")).strip()
         if action == "delete_lane":
             await lane_manager.remove_lane(lane_id)
+            try:
+                save_lanes_state(lane_manager.get_current_lane_configs())
+            except OSError:
+                logger.debug("Could not persist lane state after delete_lane")
             return {"ok": True, "lane_id": lane_id}
         if action == "sleep_lane":
             status = await lane_manager.sleep_lane(

logos/src/logos/capacity/capacity_planner.py

@@ -288,7 +288,8 @@ def _log_cluster_summary(self, provider_ids: List[int]) -> None:
         for pid in provider_ids:
             snap = self._registry.peek_runtime_snapshot(pid) if self._registry else None
             if snap is None:
-                lines.append(f"{paint('⊘', RED)} provider={pid} {paint('offline', DIM)}")
+                name = self._facade.get_provider_name(pid) or "?"
+                lines.append(f"{paint('⊘', RED)} provider={pid} worker={paint(name, BOLD)} {paint('offline', DIM)}")
                 continue
 
             connected += 1

logos/src/logos/sdi/logosnode_facade.py

@@ -183,6 +183,11 @@ def provider_ids(self) -> list[int]:
         with self._lock:
             return list(self._providers.keys())
 
+    def get_provider_name(self, provider_id: int) -> str | None:
+        """Return the display name for a provider, or None if unknown."""
+        provider = self._providers.get(int(provider_id))
+        return provider.name if provider else None
+
     def debug_state(self) -> Dict[str, Dict]:
         with self._lock:
             providers: Dict[str, Dict] = {}