Dimensional Unified TUI dio

.gitignore

@@ -3,6 +3,7 @@
 **/*.ignore.*
 
 .vscode/
+MUJOCO_LOG.TXT
 
 # Ignore Python cache files
 __pycache__/
@@ -11,6 +12,7 @@ __pycache__/
 # Ignore virtual environment directories
 *venv*/
 .venv*/
+.venv
 .ssh/
 .direnv/
 

dimos/agents/mcp/mcp_adapter.py

@@ -143,9 +143,9 @@ def from_run_entry(cls, entry: Any | None = None, timeout: int = DEFAULT_TIMEOUT
         Falls back to the default URL if no entry is found.
         """
         if entry is None:
-            from dimos.core.run_registry import list_runs
+            from dimos.core.instance_registry import list_running
 
-            runs = list_runs(alive_only=True)
+            runs = list_running()
             entry = runs[0] if runs else None
 
         if entry is not None and hasattr(entry, "mcp_url") and entry.mcp_url:

dimos/agents/mcp/mcp_server.py

@@ -203,12 +203,12 @@ def on_system_modules(self, modules: list[RPCClient]) -> None:
     @skill
     def server_status(self) -> str:
         """Get MCP server status: main process PID, deployed modules, and skill count."""
-        from dimos.core.run_registry import get_most_recent
+        from dimos.core.instance_registry import list_running
 
         skills: list[SkillInfo] = app.state.skills
         modules = list(dict.fromkeys(s.class_name for s in skills))
-        entry = get_most_recent()
-        pid = entry.pid if entry else os.getpid()
+        running = list_running()
+        pid = running[0].pid if running else os.getpid()
         return json.dumps(
             {
                 "pid": pid,

dimos/agents_deprecated/memory/image_embedding.py

@@ -63,7 +63,7 @@ def __init__(self, model_name: str = "clip", dimensions: int = 512) -> None:
     def _initialize_model(self):  # type: ignore[no-untyped-def]
         """Initialize the specified embedding model."""
         try:
-            import onnxruntime as ort  # type: ignore[import-untyped]
+            import onnxruntime as ort  # type: ignore[import-untyped,import-not-found]
             import torch  # noqa: F401
             from transformers import (  # type: ignore[import-untyped]
                 AutoFeatureExtractor,

dimos/core/blueprints.py

@@ -485,6 +485,12 @@ def build(
         self._verify_no_name_conflicts()
 
         logger.info("Starting the modules")
+        # Auto-compute worker count if not explicitly set
+        if global_config.n_workers is None:
+            import math
+
+            n_modules = len(self._active_blueprints)
+            global_config.n_workers = max(2, math.ceil(n_modules * 0.7))
         module_coordinator = ModuleCoordinator(cfg=global_config)
         module_coordinator.start()