#[non_exhaustive]pub enum PartitionExecutionError {
Show 43 variants
MissingBoundedCompletionPolicy,
CommunicationDeadlineExceeded {
operation: CommunicationOperation,
phase: DistributedExecutionPhase,
route: Option<CommunicationRouteId>,
cancellation: CompletionCancellationMode,
},
CommunicationCompletionFailed {
operation: CommunicationOperation,
phase: DistributedExecutionPhase,
route: Option<CommunicationRouteId>,
error: String,
},
CommunicationSubmissionFailed {
operation: CommunicationOperation,
phase: DistributedExecutionPhase,
route: Option<CommunicationRouteId>,
error: String,
},
CommunicationPoisoned {
operation: CommunicationOperation,
phase: DistributedExecutionPhase,
route: Option<CommunicationRouteId>,
cancellation: CompletionCancellationMode,
},
RecoveryAgreementWithoutFailure {
phase: DistributedExecutionPhase,
},
ResourceCount {
expected_groups: usize,
actual_groups: usize,
expected_routes: usize,
actual_routes: usize,
},
ResourceIdentity {
expected: u64,
actual: u64,
},
UnknownGroup(CollectiveGroupId),
NotGroupMember(CollectiveGroupId),
UnknownRoute(CommunicationRouteId),
RouteSubmissionWave {
first: CommunicationRouteId,
expected: usize,
actual: usize,
},
NotRouteEndpoint(CommunicationRouteId),
OperationNotSelected {
resource: String,
operation: CommunicationOperation,
},
TensorDtype {
dtype: TensorDtype,
},
TensorLimits {
shape: Vec<usize>,
},
CommunicationAxis {
axis: usize,
rank: usize,
},
CommunicationShapeOverflow,
CommunicationOutputShape {
expected: Vec<usize>,
actual: Vec<usize>,
},
MissingTensorLimits,
TensorCount {
expected_at_most: usize,
actual: usize,
},
PeerCount {
expected: usize,
actual: usize,
},
PeerCountLimit {
maximum: usize,
},
BoundaryTensorCount {
boundary: &'static str,
expected: usize,
actual: usize,
},
BoundaryShape {
role: String,
expected: Vec<usize>,
actual: Vec<usize>,
},
BoundaryDtype {
role: String,
expected: TensorDtype,
actual: TensorDtype,
},
BoundaryFraming(String),
OutputOwnerNotMember {
rank: usize,
group: CollectiveGroupId,
},
OutputOwnership {
rank: usize,
owner: usize,
},
MissingOutputPublication,
GroupCount {
graph: usize,
contracts: usize,
drivers: usize,
},
DriverGroup {
group: usize,
},
RouteGroup(CommunicationRouteId),
RouteDependency(CommunicationRouteId),
RouteCount {
plan: usize,
manifest: usize,
},
RouteDescriptorMismatch {
route: CommunicationRouteId,
planned_source: usize,
planned_destination: usize,
manifest_source: usize,
manifest_destination: usize,
},
RouteOwnerMissing {
route: CommunicationRouteId,
rank: usize,
group: usize,
},
Communication(String),
RemotePhaseFailure(DistributedExecutionPhase),
ResidencyPolicyMismatch,
OperationPolicyUnavailable(CommunicationOperation),
InexactOperationRequirement {
group: CollectiveGroupId,
operation: CommunicationOperation,
},
CommunicationPolicyMismatch,
}Expand description
Cold-path validation or execution failure in the neutral partition driver.
Variants (Non-exhaustive)§
This enum is marked as non-exhaustive
Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.
MissingBoundedCompletionPolicy
A partition communication object omitted the selected bounded-wait contract.
CommunicationDeadlineExceeded
Exact communication did not complete by its selected deadline.
Fields
§
operation: CommunicationOperation§
phase: DistributedExecutionPhase§
route: Option<CommunicationRouteId>§
cancellation: CompletionCancellationModeCommunicationCompletionFailed
A submitted communication reported a terminal error while completing.
Fields
§
operation: CommunicationOperation§
phase: DistributedExecutionPhase§
route: Option<CommunicationRouteId>CommunicationSubmissionFailed
Native submission failed after entering one communication operation.
Fields
§
operation: CommunicationOperation§
phase: DistributedExecutionPhase§
route: Option<CommunicationRouteId>CommunicationPoisoned
A prior timed-out or failed operation left this communicator unsafe for reuse.
Fields
§
operation: CommunicationOperation§
phase: DistributedExecutionPhase§
route: Option<CommunicationRouteId>§
cancellation: CompletionCancellationModeRecoveryAgreementWithoutFailure
A recovery-only agreement was invoked without a local failure or prior poison.
Fields
§
phase: DistributedExecutionPhaseResourceCount
Native resources were not paired one-for-one with manifest descriptors.
ResourceIdentity
A native resource was paired with a different opaque manifest identity.
UnknownGroup(CollectiveGroupId)
NotGroupMember(CollectiveGroupId)
UnknownRoute(CommunicationRouteId)
RouteSubmissionWave
NotRouteEndpoint(CommunicationRouteId)
OperationNotSelected
TensorDtype
Fields
§
dtype: TensorDtypeTensorLimits
CommunicationAxis
CommunicationShapeOverflow
CommunicationOutputShape
MissingTensorLimits
TensorCount
PeerCount
PeerCountLimit
BoundaryTensorCount
BoundaryShape
BoundaryDtype
BoundaryFraming(String)
OutputOwnerNotMember
OutputOwnership
MissingOutputPublication
GroupCount
DriverGroup
RouteGroup(CommunicationRouteId)
RouteDependency(CommunicationRouteId)
RouteCount
RouteDescriptorMismatch
Fields
§
route: CommunicationRouteIdRouteOwnerMissing
Communication(String)
RemotePhaseFailure(DistributedExecutionPhase)
ResidencyPolicyMismatch
InexactOperationRequirement
CommunicationPolicyMismatch
Trait Implementations§
Source§impl Debug for PartitionExecutionError
impl Debug for PartitionExecutionError
Source§impl Display for PartitionExecutionError
impl Display for PartitionExecutionError
Source§impl Error for PartitionExecutionError
impl Error for PartitionExecutionError
1.30.0 · Source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
Returns the lower-level source of this error, if any. Read more
1.0.0 · Source§fn description(&self) -> &str
fn description(&self) -> &str
👎Deprecated since 1.42.0:
use the Display impl or to_string()
Auto Trait Implementations§
impl Freeze for PartitionExecutionError
impl RefUnwindSafe for PartitionExecutionError
impl Send for PartitionExecutionError
impl Sync for PartitionExecutionError
impl Unpin for PartitionExecutionError
impl UnsafeUnpin for PartitionExecutionError
impl UnwindSafe for PartitionExecutionError
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more