class Orchestrator(BaseAgent):
    # Define fields with type hints
    name: str
    description: str

    def __init__(
            self,
            name: str | None = None,
            description: str | None = None,
            report_planner: LlmAgent | None = None,
            report_executor: LlmAgent | None = None,
            report_aggregator: LlmAgent | None = None,
            # Add **kwargs to capture any other arguments BaseAgent might need
            **kwargs: Any
        ):

        # Determine the final values for initialization
        # Use passed values or defaults (including class-level defaults for name/description)
        final_name = name if name is not None else "RecursiveOrchestrator"
        final_description = description if description is not None else "Manages task planning, execution, decomposition, and aggregation."
        # Ensure sub-agents are instantiated here if not passed in
        report_planner = report_planner if report_planner is not None else PlannerAgent()
        final_sub_agents_list = [report_planner]

        super().__init__(
            name=final_name,
            description=final_description,
            #Pass the list of top-level sub-agents this orchestrator uses
            sub_agents=final_sub_agents_list,
            **kwargs
        )

    async def _run_async_impl(self, ctx: InvocationContext) -> AsyncGenerator[Event, None]:
        """
        Main entry point for the recursive orchestrator.
        Handles initial setup and recursive task processing.
        """
        initial_task = ctx.session.events[0].content.parts[0].text
        logger.info(f"Initial task: {initial_task}")
        # Create a response event
        response_text = f"Processing task: {initial_task}"
        yield Event(
            author=self.name,
            actions=EventActions(transfer_to_agent=self.find_sub_agent("PlannerAgent").name)
        )