Struct AttemptHandle 

pub struct AttemptHandle(/* private fields */);

Cloneable record-only capability shared by every native fragment of one invocation. It cannot terminalize the attempt.

Implementations

impl AttemptHandle

pub fn attempt_id(&self) -> AttemptId

The engine-minted identity of this invocation.

pub fn cancellation(&self) -> AttemptCancellation

The attempt-scoped cooperative cancellation signal and deadline.

pub fn is_terminal(&self) -> bool

Returns whether the attempt outcome is already terminal.

pub fn disposition(&self) -> Option<AttemptDisposition>

The current disposition, when planning or execution has classified it.

pub fn record_planning_started(&self) -> Result<(), AttemptLifecycleError>

pub fn record_planning_finished(&self) -> Result<(), AttemptLifecycleError>

pub fn set_disposition( &self, disposition: AttemptDisposition, ) -> Result<(), AttemptLifecycleError>

pub fn record_composed_schedule_projection( &self, projection: AttemptComposedScheduleProjection, ) -> Result<(), AttemptLifecycleError>

Publishes the engine-owned composed schedule into this attempt’s immutable report. The lifecycle verifies the projection’s attempt placement against the already-recorded admission fact; callers cannot replace the schedule after finalization.

pub fn record_physical_execution_started( &self, ) -> Result<(), AttemptLifecycleError>

pub fn record_gpu_execution_started(&self) -> Result<(), AttemptLifecycleError>

pub fn record_native_failure(&self, error: &QueryError)

Retains the safe, closed projection of a borrowed native error without granting terminalization or sealing authority.

The record-only capability is used by adapter paths whose admitted handle may begin cleanup before the outer DataFusion wrapper returns the original error to the attempt owner. The full error remains on that returned path; this records only its bounded stable summary.

Trait Implementations

impl Clone for AttemptHandle

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AttemptHandle

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.