while True:
    with self._state:
        if self._state.execution_status in [
            ConversationExecutionStatus.PAUSED,
            ConversationExecutionStatus.STUCK,
        ]:
            break

        # Handle stop hooks on FINISHED
        if (
            self._state.execution_status
            == ConversationExecutionStatus.FINISHED
        ):
…
            # No hooks or hooks allowed stopping
            break

        # Check for stuck patterns if enabled
        if self._check_stuck_or_nudge():
            continue
…
            self.agent.step(
                self, on_event=self._on_event, on_token=self._on_token
            )
        iteration += 1
…
        budget_detail = self._budget_exceeded_detail()
        if budget_detail and (
            self._state.execution_status
            != ConversationExecutionStatus.FINISHED
        ):
            self._emit_run_limit_error("MaxBudgetReached", budget_detail)
            break

        if iteration >= self.max_iteration_per_run:
…
            error_msg = (
                f"Agent reached maximum iterations limit "
                f"({self.max_iteration_per_run})."
            )
            logger.error(error_msg)
            self._state.execution_status = ConversationExecutionStatus.ERROR
            self._on_event(
                ConversationErrorEvent(
                    source="environment",
                    code="MaxIterationsReached",
                    detail=error_msg,
                )
            )
            break

Warm-up