manual_slop/conductor/tracks/async_tool_execution_20260303/plan.md

Implementation Plan: Asynchronous Tool Execution Engine (async_tool_execution_20260303)

Phase 1: Engine Refactoring

• Task: Initialize MMA Environment activate_skill mma-orchestrator
• Task: Refactor mcp_client.py for async execution
  • WHERE: mcp_client.py
  • WHAT: Convert tool execution wrappers to async def or wrap them in thread executors.
  • HOW: Use asyncio.to_thread for blocking I/O bound tools.
  • SAFETY: Ensure thread safety for shared resources.
• Task: Update ai_client.py dispatcher
  • WHERE: ai_client.py (around tool dispatch loop)
  • WHAT: Use asyncio.gather to execute multiple tool calls concurrently.
  • HOW: Await the gathered results before proceeding with the AI loop.
  • SAFETY: Handle tool execution exceptions gracefully without crashing the gather group.
• Task: Conductor - User Manual Verification 'Phase 1' (Protocol in workflow.md)

Phase 2: Testing & Validation

• Task: Implement async tool execution tests
  • WHERE: tests/test_async_tools.py
  • WHAT: Write a test verifying that multiple tools run concurrently (e.g., measuring total time vs sum of individual sleep times).
  • HOW: Use a mock tool with an explicit sleep delay.
  • SAFETY: Standard pytest setup.
• Task: Full Suite Validation
• Task: Conductor - User Manual Verification 'Phase 2' (Protocol in workflow.md)