Initialize the plan executor. Args: mcp_client: Shared MCP client (same instance as the agentic loop uses for its own tool calls). llm_client: Shared LLM client (same instance as the agentic loop). logger: Logger for execution events (plan
(
self,
mcp_client: MCPClient,
llm_client: LLMClient,
logger: Logger,
output_dir: str,
)
| 80 | """ |
| 81 | |
| 82 | def __init__( |
| 83 | self, |
| 84 | mcp_client: MCPClient, |
| 85 | llm_client: LLMClient, |
| 86 | logger: Logger, |
| 87 | output_dir: str, |
| 88 | ): |
| 89 | """Initialize the plan executor. |
| 90 | |
| 91 | Args: |
| 92 | mcp_client: Shared MCP client (same instance as the agentic loop |
| 93 | uses for its own tool calls). |
| 94 | llm_client: Shared LLM client (same instance as the agentic loop). |
| 95 | logger: Logger for execution events (plan_execution_start/end/error). |
| 96 | output_dir: Base output directory. Plan outputs go to |
| 97 | {output_dir}/plan_outputs/{task_name}/. |
| 98 | """ |
| 99 | self.mcp_client = mcp_client |
| 100 | self.llm_client = llm_client |
| 101 | self.logger = logger |
| 102 | self.output_dir = output_dir |
| 103 | self._parser = YAMLTaskParser() |
| 104 | |
| 105 | def execute( |
| 106 | self, |
nothing calls this directly
no test coverage detected