Method cancel_current_turn

src/apps/cli/src/agent/core_adapter.rs:271–283

(&self)

    }

    async fn cancel_current_turn(&self) -> Result<()> {
        let session_id_guard = self.session_id.lock().await;
        let turn_id_guard = self.current_turn_id.lock().await;

        if let (Some(session_id), Some(turn_id)) = (&*session_id_guard, &*turn_id_guard) {
            tracing::info!("Cancelling turn: session={}, turn={}", session_id, turn_id);
            self.coordinator
                .cancel_dialog_turn(session_id, turn_id)
                .await?;
        }

        Ok(())
    }

    async fn create_new_session(&self, agent_type: &str) -> Result<String> {
        let mut session_id_guard = self.session_id.lock().await;