vyre-runtime 0.7.2

Persistent megakernel + io_uring zero-copy streaming runtime for vyre typed programs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

//! Structured artifact-session recovery policy.

use vyre_driver::backend::ErrorCode;
use vyre_driver::{BackendError, DeviceIdentity};
use vyre_foundation::diagnostics::RetryClass;

use crate::artifact_admission::{ArtifactSession, ArtifactSessionError};

/// Classify a backend failure into the shared workflow retry protocol.

/// Classify a backend failure without parsing human-readable text.
#[must_use]
pub fn classify_backend_error(error: &BackendError) -> RetryClass {
    match error.code() {
        ErrorCode::DeviceLost => RetryClass::NewDevice,
        ErrorCode::DeviceOutOfMemory | ErrorCode::PoisonedLock => RetryClass::SameDevice,
        ErrorCode::UnsupportedFeature
        | ErrorCode::KernelCompileFailed
        | ErrorCode::InvalidProgram
        | ErrorCode::CooperativeResidencyExceeded
        | ErrorCode::DispatchFailed
        | ErrorCode::Unknown => RetryClass::Never,
        _ => RetryClass::Never,
    }
}

/// Rematerialize an authenticated artifact only for a structured device-loss failure.
///
/// This function never invokes semantic optimization, lowering, or target compilation.
///
/// # Errors
///
/// Returns the original backend failure for any non-device-loss class. Returns the
/// admission or materialization failure when device reacquisition fails.
pub fn recover_artifact_session(
    session: &ArtifactSession,
    failure: BackendError,
) -> Result<DeviceIdentity, ArtifactSessionError> {
    if classify_backend_error(&failure) != RetryClass::NewDevice {
        return Err(failure.into());
    }
    session.rematerialize()
}