class AgentSystem:
    def __init__(self, llm, tools, memory):
        self.planner = WorkflowPlanner(llm)
        self.executor = TaskOrchestrator(llm, tools)
        self.memory = PersistentContext(memory)
        self.monitor = ExecutionMonitor()

    def process_request(self, request):
        # Multi-step orchestration
        context = self.memory.load_context(request.session_id)
        plan = self.planner.create_plan(request, context)

        execution_result = self.executor.execute_plan(
            plan, 
            callbacks=[self.monitor.track_progress]
        )

        self.memory.save_context(context, execution_result)
        return execution_result.get_structured_output()

        __
        __