src/pipeline_steps/plan_step.py

from core.pipeline.step import PipelineStep

class PlanStep(PipelineStep):
    name = "plan_agent"

    def __init__(self, agent):
        self.agent = agent

    async def run(self, context):
        plan_result = await self.agent.run(
            context.summary,
            language=context.language,
            profile=context.runner_profile,
            goal=context.active_goal
        )
        context.plan = plan_result.get("plan", "")