Claude Code: Fix A2A communication - correct status file path resolution

- Fix health_monitor.py to check CAIN_STATUS_PATH first (matches app.py)
- Fix error_handlers.py to use same path priority order
- This ensures consistent status file reads/writes across all modules

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

error_handlers.py

@@ -94,20 +94,36 @@ def _resolve_status_file() -> Path:
     if env_path:
         return Path(env_path)
 
-    # Priority 2: /app/.openclaw/agents/cain_status.json (actual location)
+    # Priority 2: CAIN_STATUS_FILE env var (legacy)
+    env_path = os.environ.get('CAIN_STATUS_FILE')
+    if env_path:
+        return Path(env_path)
+
+    # Priority 3: OPENCLAW_DATA_DIR + cain_status.json
+    data_dir = os.environ.get('OPENCLAW_DATA_DIR')
+    if data_dir:
+        data_path = Path(data_dir) / "cain_status.json"
+        if data_path.exists():
+            return data_path
+
+    # Priority 4: /data/cain_status.json (Docker volume mount, default)
+    data_path = Path("/data/cain_status.json")
+    if data_path.exists():
+        return data_path
+
+    # Priority 5: /app/.openclaw/agents/cain_status.json (actual location)
     openclaw_status = Path(__file__).parent / ".openclaw" / "agents" / "cain_status.json"
     if openclaw_status.exists():
         return openclaw_status
 
-    # Priority 3: /app/cain_status.json (legacy location)
+    # Priority 6: /app/cain_status.json (legacy location)
     app_path = Path("/app/cain_status.json")
+    if app_path.parent.exists():
+        return app_path
 
-    # Priority 4: Script directory as final fallback
-    if not app_path.parent.exists():
-        script_dir = Path(os.path.dirname(__file__))
-        return script_dir / "cain_status.json"
-
-    return app_path
+    # Priority 7: Script directory as final fallback
+    script_dir = Path(os.path.dirname(__file__))
+    return script_dir / "cain_status.json"
 
 STATUS_FILE = _resolve_status_file()
 

openclaw/.openclaw/health_monitor.py

@@ -777,30 +777,44 @@ def reset_health_monitor():
 
 def _find_status_file() -> Path:
     """Dynamically locate cain_status.json using multiple fallback strategies."""
-    # Strategy 1: Use environment variable if set (highest priority)
+    # Strategy 1: CAIN_STATUS_PATH (set by app.py, highest priority)
+    env_path = os.environ.get("CAIN_STATUS_PATH")
+    if env_path:
+        return Path(env_path)
+
+    # Strategy 2: CAIN_STATUS_FILE (legacy, for compatibility)
     env_path = os.environ.get("CAIN_STATUS_FILE")
     if env_path:
         return Path(env_path)
 
-    # Strategy 2: Relative to health_monitor.py (in .openclaw/ directory)
-    # In workspace: openclaw/.openclaw/health_monitor.py -> openclaw/.openclaw/agents/
-    # In Docker: /app/openclaw/.openclaw/health_monitor.py -> /app/openclaw/.openclaw/agents/
+    # Strategy 3: OPENCLAW_DATA_DIR + cain_status.json
+    data_dir = os.environ.get("OPENCLAW_DATA_DIR")
+    if data_dir:
+        data_path = Path(data_dir) / "cain_status.json"
+        if data_path.exists():
+            return data_path
+
+    # Strategy 4: /data/cain_status.json (Docker volume mount)
+    data_path = Path("/data/cain_status.json")
+    if data_path.exists():
+        return data_path
+
+    # Strategy 5: Relative to health_monitor.py (in .openclaw/ directory)
     base_dir = Path(__file__).parent.resolve()
     relative_path = base_dir / "agents" / "cain_status.json"
     if relative_path.exists():
         return relative_path
 
-    # Strategy 3: From /app root (Docker) or workspace root (local)
-    # Handles cases where health_monitor.py might be imported from different locations
-    workspace_root = base_dir.parent.parent  # Go up two levels from .openclaw/
+    # Strategy 6: From /app root (Docker) or workspace root (local)
+    workspace_root = base_dir.parent.parent
     if workspace_root.name == "openclaw":
-        workspace_root = workspace_root.parent  # Go up one more level
+        workspace_root = workspace_root.parent
     root_path = workspace_root / "openclaw" / ".openclaw" / "agents" / "cain_status.json"
     if root_path.exists():
         return root_path
 
-    # Strategy 4: Fall back to the expected path (may not exist, but that's OK)
-    return relative_path
+    # Strategy 7: Fall back to /data/cain_status.json (default for Docker)
+    return Path("/data/cain_status.json")
 
 
 def read_current_stage() -> str: