v0.5.7

Author: annschulte

plexus/__init__.py

@@ -28,5 +28,5 @@
 from plexus.config import load_config, save_config
 from plexus.typed_commands import param, CommandRegistry
 
-__version__ = "0.5.6"
+__version__ = "0.5.7"
 __all__ = ["Plexus", "param", "CommandRegistry", "load_config", "save_config"]

plexus/adapters/__init__.py

@@ -39,7 +39,7 @@ def connect(self) -> bool:
             # Connect to your protocol
             return True
 
-        def poll(self) -> list[Metric]:
+        def poll(self) -> "List[Metric]":
             # Read data and return metrics
             return [Metric("sensor.temp", 72.5)]
 

plexus/adapters/base.py

@@ -31,7 +31,7 @@ def disconnect(self) -> None:
             if self._serial:
                 self._serial.close()
 
-        def poll(self) -> list[Metric]:
+        def poll(self) -> "List[Metric]":
             line = self._serial.readline().decode().strip()
             # Parse your protocol format
             metric, value = line.split(":")

plexus/commands.py

@@ -20,7 +20,7 @@
 import os
 import shlex
 import subprocess
-from typing import Optional, Callable, List
+from typing import Optional, Callable, List, Tuple
 
 logger = logging.getLogger(__name__)
 
@@ -62,7 +62,7 @@ def __init__(
         self.on_status = on_status or (lambda x: None)
         self._current_process: Optional[subprocess.Popen] = None
 
-    def is_command_allowed(self, command: str) -> tuple[bool, str]:
+    def is_command_allowed(self, command: str) -> Tuple[bool, str]:
         """Check if a command is allowed by the allowlist/denylist policy.
 
         Returns (allowed, reason) tuple.

plexus/detect.py

@@ -101,7 +101,7 @@ class SystemInfo:
 # Existing Detection Functions
 # ─────────────────────────────────────────────────────────────────────────────
 
-def detect_sensors(bus: int = 1) -> tuple[Optional["SensorHub"], list]:
+def detect_sensors(bus: int = 1) -> Tuple[Optional["SensorHub"], List]:
     """Detect I2C sensors and create a SensorHub.
 
     Returns:
@@ -121,7 +121,7 @@ def detect_sensors(bus: int = 1) -> tuple[Optional["SensorHub"], list]:
         return None, []
 
 
-def detect_cameras() -> tuple[Optional["CameraHub"], list]:
+def detect_cameras() -> Tuple[Optional["CameraHub"], List]:
     """Detect connected cameras and create a CameraHub.
 
     Returns:
@@ -141,7 +141,7 @@ def detect_cameras() -> tuple[Optional["CameraHub"], list]:
         return None, []
 
 
-def detect_can() -> tuple[Optional[list["DetectedCAN"]], list["DetectedCAN"], list["DetectedCAN"]]:
+def detect_can() -> Tuple[Optional[List["DetectedCAN"]], List["DetectedCAN"], List["DetectedCAN"]]:
     """Detect CAN interfaces.
 
     Returns:
@@ -159,7 +159,7 @@ def detect_can() -> tuple[Optional[list["DetectedCAN"]], list["DetectedCAN"], li
         return None, [], []
 
 
-def detect_mavlink() -> list["DetectedMAVLink"]:
+def detect_mavlink() -> List["DetectedMAVLink"]:
     """Detect MAVLink connections (UDP, TCP, serial).
 
     Returns:

plexus/streaming.py

@@ -47,12 +47,12 @@ def __init__(
         self.on_status = on_status or (lambda x: None)
         self.persist_fn = persist_fn
 
-        self._active_streams: dict[str, asyncio.Task] = {}
-        self._active_camera_streams: dict[str, asyncio.Task] = {}
-        self._active_can_streams: dict[str, asyncio.Task] = {}
-        self._can_instances: dict[str, Any] = {}  # channel -> CANAdapter
-        self._active_mavlink_streams: dict[str, asyncio.Task] = {}
-        self._mavlink_instances: dict[str, Any] = {}  # conn_string -> MAVLinkAdapter
+        self._active_streams: Dict[str, asyncio.Task] = {}
+        self._active_camera_streams: Dict[str, asyncio.Task] = {}
+        self._active_can_streams: Dict[str, asyncio.Task] = {}
+        self._can_instances: Dict[str, Any] = {}  # channel -> CANAdapter
+        self._active_mavlink_streams: Dict[str, asyncio.Task] = {}
+        self._mavlink_instances: Dict[str, Any] = {}  # conn_string -> MAVLinkAdapter
         self._recording: bool = False
 
     # =========================================================================

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "plexus-agent"
-version = "0.5.6"
+version = "0.5.7"
 description = "Send sensor data to Plexus in one line of code"
 readme = "README.md"
 license = "Apache-2.0"