-
Notifications
You must be signed in to change notification settings - Fork 26
Add validation + compatibility tests for DeepLabCut-live #56
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: master
Are you sure you want to change the base?
Changes from 7 commits
41db059
4c97d58
1ad9a61
7e4b753
d9c0fdf
693c931
622722b
60a0e8a
990654b
882717b
e52477f
34b8727
edec653
fd17969
ebfad63
5c03b4e
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -15,7 +15,7 @@ | |
| import numpy as np | ||
| from PySide6.QtCore import QObject, Signal | ||
|
|
||
| from dlclivegui.config import DLCProcessorSettings | ||
| from dlclivegui.config import DLCProcessorSettings, ModelType | ||
| from dlclivegui.processors.processor_utils import instantiate_from_scan | ||
| from dlclivegui.temp import Engine # type: ignore # TODO use main package enum when released | ||
|
|
||
|
|
@@ -37,6 +37,63 @@ | |
| class PoseResult: | ||
| pose: np.ndarray | None | ||
| timestamp: float | ||
| packet: "PosePacket | None" = None | ||
|
|
||
|
|
||
| @dataclass(slots=True, frozen=True) | ||
| class PoseSource: | ||
| backend: str # e.g. "DLCLive" | ||
C-Achard marked this conversation as resolved.
Outdated
Show resolved
Hide resolved
|
||
| model_type: ModelType | None = None | ||
|
|
||
|
|
||
| @dataclass(slots=True, frozen=True) | ||
| class PosePacket: | ||
| schema_version: int = 0 | ||
| keypoints: np.ndarray | None = None | ||
| keypoint_names: list[str] | None = None | ||
| individual_ids: list[str] | None = None | ||
| source: PoseSource = PoseSource(backend="DLCLive") | ||
| raw: Any | None = None | ||
|
|
||
|
|
||
| def validate_pose_array(pose: Any, *, source_backend: str = "DLCLive") -> np.ndarray: | ||
| """ | ||
| Validate pose output shape and dtype. | ||
|
|
||
| Accepted runner output shapes: | ||
| - (K, 3): single-animal | ||
| - (N, K, 3): multi-animal | ||
| """ | ||
|
Comment on lines
+65
to
+71
|
||
| try: | ||
| arr = np.asarray(pose) | ||
| except Exception as exc: | ||
| raise ValueError( | ||
| f"{source_backend} returned an invalid pose output format: could not convert to array ({exc})" | ||
|
Comment on lines
+64
to
+76
|
||
| ) from exc | ||
|
|
||
| if arr.ndim not in (2, 3): | ||
| raise ValueError( | ||
| f"{source_backend} returned an invalid pose output format: expected a 2D or 3D array, got ndim={arr.ndim}, shape={arr.shape!r}" | ||
| ) | ||
|
|
||
| if arr.shape[-1] != 3: | ||
| raise ValueError( | ||
| f"{source_backend} returned an invalid pose output format: expected last dimension size 3 (x, y, likelihood), got shape={arr.shape!r}" | ||
| ) | ||
|
|
||
| if arr.ndim == 2 and arr.shape[0] <= 0: | ||
| raise ValueError(f"{source_backend} returned an invalid pose output format: expected at least one keypoint") | ||
| if arr.ndim == 3 and (arr.shape[0] <= 0 or arr.shape[1] <= 0): | ||
| raise ValueError( | ||
| f"{source_backend} returned an invalid pose output format: expected at least one individual and one keypoint, got shape={arr.shape!r}" | ||
| ) | ||
|
|
||
| if not np.issubdtype(arr.dtype, np.number): | ||
| raise ValueError( | ||
| f"{source_backend} returned an invalid pose output format: expected numeric values, got dtype={arr.dtype}" | ||
| ) | ||
|
|
||
| return arr | ||
|
|
||
|
|
||
| @dataclass | ||
|
|
@@ -269,8 +326,17 @@ | |
| # Time GPU inference (and processor overhead when present) | ||
| with self._timed_processor() as proc_holder: | ||
| inference_start = time.perf_counter() | ||
| pose = self._dlc.get_pose(frame, frame_time=timestamp) | ||
| raw_pose: Any = self._dlc.get_pose(frame, frame_time=timestamp) | ||
| inference_time = time.perf_counter() - inference_start | ||
| pose_arr: np.ndarray = validate_pose_array(raw_pose, source_backend="DLCLive") | ||
| pose_packet = PosePacket( | ||
| schema_version=0, | ||
| keypoints=pose_arr, | ||
| keypoint_names=None, | ||
| individual_ids=None, | ||
| source=PoseSource(backend="DLCLive", model_type=self._settings.model_type), | ||
| raw=raw_pose, | ||
| ) | ||
|
|
||
| processor_overhead = 0.0 | ||
| gpu_inference_time = inference_time | ||
|
|
@@ -280,7 +346,7 @@ | |
|
|
||
| # Emit pose (measure signal overhead) | ||
| signal_start = time.perf_counter() | ||
| self.pose_ready.emit(PoseResult(pose=pose, timestamp=timestamp)) | ||
| self.pose_ready.emit(PoseResult(pose=pose_packet.keypoints, timestamp=timestamp, packet=pose_packet)) | ||
| signal_time = time.perf_counter() - signal_start | ||
|
|
||
| end_ts = time.perf_counter() | ||
|
|
||
| Original file line number | Diff line number | Diff line change | ||||||||||||||||||||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| @@ -0,0 +1,121 @@ | ||||||||||||||||||||||||||||||||||||
| from __future__ import annotations | ||||||||||||||||||||||||||||||||||||
|
|
||||||||||||||||||||||||||||||||||||
| import importlib.metadata | ||||||||||||||||||||||||||||||||||||
| import inspect | ||||||||||||||||||||||||||||||||||||
| import os | ||||||||||||||||||||||||||||||||||||
| from pathlib import Path | ||||||||||||||||||||||||||||||||||||
|
|
||||||||||||||||||||||||||||||||||||
| import numpy as np | ||||||||||||||||||||||||||||||||||||
| import pytest | ||||||||||||||||||||||||||||||||||||
|
|
||||||||||||||||||||||||||||||||||||
|
|
||||||||||||||||||||||||||||||||||||
| def _get_signature_params(callable_obj) -> tuple[set[str], bool]: | ||||||||||||||||||||||||||||||||||||
| """ | ||||||||||||||||||||||||||||||||||||
| Return allowed keyword names for callable, allowing for **kwargs. | ||||||||||||||||||||||||||||||||||||
|
|
||||||||||||||||||||||||||||||||||||
| Example: | ||||||||||||||||||||||||||||||||||||
| >>> params, accepts_var_kw = _get_signature_params(lambda x, y, **kwargs: None, {"x", "y"}) | ||||||||||||||||||||||||||||||||||||
| >>> params == {"x", "y"} | ||||||||||||||||||||||||||||||||||||
| True | ||||||||||||||||||||||||||||||||||||
| >>> accepts_var_kw | ||||||||||||||||||||||||||||||||||||
| True | ||||||||||||||||||||||||||||||||||||
| """ | ||||||||||||||||||||||||||||||||||||
| sig = inspect.signature(callable_obj) | ||||||||||||||||||||||||||||||||||||
| params = sig.parameters | ||||||||||||||||||||||||||||||||||||
| accepts_var_kw = any(p.kind == inspect.Parameter.VAR_KEYWORD for p in params.values()) | ||||||||||||||||||||||||||||||||||||
| return params, accepts_var_kw | ||||||||||||||||||||||||||||||||||||
|
Comment on lines
+12
to
+26
|
||||||||||||||||||||||||||||||||||||
|
|
||||||||||||||||||||||||||||||||||||
|
|
||||||||||||||||||||||||||||||||||||
| @pytest.mark.dlclive_compat | ||||||||||||||||||||||||||||||||||||
| def test_dlclive_package_is_importable(): | ||||||||||||||||||||||||||||||||||||
| from dlclive import DLCLive # noqa: PLC0415 | ||||||||||||||||||||||||||||||||||||
|
|
||||||||||||||||||||||||||||||||||||
| assert DLCLive is not None | ||||||||||||||||||||||||||||||||||||
| # Helpful for CI logs to confirm matrix install result. | ||||||||||||||||||||||||||||||||||||
| _ = importlib.metadata.version("deeplabcut-live") | ||||||||||||||||||||||||||||||||||||
|
|
||||||||||||||||||||||||||||||||||||
|
|
||||||||||||||||||||||||||||||||||||
| @pytest.mark.dlclive_compat | ||||||||||||||||||||||||||||||||||||
| def test_dlclive_constructor_accepts_gui_expected_kwargs(): | ||||||||||||||||||||||||||||||||||||
| """ | ||||||||||||||||||||||||||||||||||||
| GUI passes these kwargs when constructing DLCLive. | ||||||||||||||||||||||||||||||||||||
| This test catches upstream API changes that would break initialization. | ||||||||||||||||||||||||||||||||||||
| """ | ||||||||||||||||||||||||||||||||||||
| from dlclive import DLCLive # noqa: PLC0415 | ||||||||||||||||||||||||||||||||||||
|
|
||||||||||||||||||||||||||||||||||||
| expected = { | ||||||||||||||||||||||||||||||||||||
| "model_path", | ||||||||||||||||||||||||||||||||||||
| "model_type", | ||||||||||||||||||||||||||||||||||||
| "processor", | ||||||||||||||||||||||||||||||||||||
| "dynamic", | ||||||||||||||||||||||||||||||||||||
| "resize", | ||||||||||||||||||||||||||||||||||||
| "precision", | ||||||||||||||||||||||||||||||||||||
| "single_animal", | ||||||||||||||||||||||||||||||||||||
| "device", | ||||||||||||||||||||||||||||||||||||
| } | ||||||||||||||||||||||||||||||||||||
| params, accepts_var_kw = _get_signature_params(DLCLive.__init__) | ||||||||||||||||||||||||||||||||||||
| missing = {name for name in expected if name not in params} | ||||||||||||||||||||||||||||||||||||
|
Comment on lines
+56
to
+62
|
||||||||||||||||||||||||||||||||||||
| params, _ = _get_signature_params(DLCLive.__init__) | |
| params = { | |
| name | |
| for name, p in params.items() | |
| if p.kind in (inspect.Parameter.KEYWORD_ONLY, inspect.Parameter.POSITIONAL_OR_KEYWORD) | |
| } | |
| missing = {name for name in expected if name not in params} | |
| params, accepts_var_kw = _get_signature_params(DLCLive.__init__) | |
| params = { | |
| name | |
| for name, p in params.items() | |
| if p.kind in (inspect.Parameter.KEYWORD_ONLY, inspect.Parameter.POSITIONAL_OR_KEYWORD) | |
| } | |
| missing = {name for name in expected if name not in params} | |
| if missing and accepts_var_kw: | |
| # DLCLive.__init__ accepts **kwargs, so GUI-passed kwargs are still supported. | |
| missing = set() |
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,40 @@ | ||
| import numpy as np | ||
| import pytest | ||
|
|
||
| from dlclivegui.services.dlc_processor import validate_pose_array | ||
|
|
||
|
|
||
| @pytest.mark.unit | ||
C-Achard marked this conversation as resolved.
Show resolved
Hide resolved
|
||
| def test_validate_pose_array_keeps_single_animal_shape(): | ||
| pose = np.ones((5, 3), dtype=np.float64) | ||
| out = validate_pose_array(pose) | ||
| assert out.shape == (5, 3) | ||
| assert out.dtype == np.float64 | ||
|
|
||
|
|
||
| @pytest.mark.unit | ||
| def test_validate_pose_array_accepts_multi_animal(): | ||
| pose = np.ones((2, 5, 3), dtype=np.float32) | ||
| out = validate_pose_array(pose) | ||
| assert out.shape == (2, 5, 3) | ||
|
|
||
|
|
||
| @pytest.mark.unit | ||
| @pytest.mark.parametrize( | ||
| "bad_pose,expected", | ||
| [ | ||
| (np.ones((5, 2), dtype=np.float32), "last dimension size 3"), | ||
| (np.ones((2, 5, 4), dtype=np.float32), "last dimension size 3"), | ||
| (np.ones((3,), dtype=np.float32), "expected a 2D or 3D array"), | ||
| ], | ||
| ) | ||
| def test_validate_pose_array_rejects_invalid_shapes(bad_pose, expected): | ||
| with pytest.raises(ValueError, match=expected): | ||
| validate_pose_array(bad_pose) | ||
|
|
||
|
|
||
| @pytest.mark.unit | ||
| def test_validate_pose_array_rejects_non_numeric(): | ||
| pose = np.array([[["x", "y", "p"]]], dtype=object) | ||
| with pytest.raises(ValueError, match="expected numeric values"): | ||
| validate_pose_array(pose) | ||
Uh oh!
There was an error while loading. Please reload this page.