Method cancel_token_slot

core/src/agent_api/runtime_events.rs:178–182

Share the per-run cancel-token slot. Used by stream worker state to observe cancellation when classifying a failed run.

(
        &self,
    )

    /// Share the per-run cancel-token slot. Used by stream worker state to
    /// observe cancellation when classifying a failed run.
    pub(super) fn cancel_token_slot(
        &self,
    ) -> Arc<tokio::sync::Mutex<Option<tokio_util::sync::CancellationToken>>> {
        Arc::clone(&self.cancel_token)
    }

    pub(super) async fn clear_cancel_token(&self) {
        *self.cancel_token.lock().await = None;