operon 0.7.0

A workflow engine for parallel, incremental scheduling of DAG-defined multiplex tasks.
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

use std::sync::PoisonError;

use thiserror::Error as ThisError;

use crate::meta_storage::{MetaResult, MetaStorageError};

/// A metadata result over the in-memory backend's error.
pub(super) type MemResult<T> = MetaResult<T, MemMetaError>;

/// In-memory-specific metadata errors.
///
/// # Stability
///
/// This enum is `#[non_exhaustive]`.
#[derive(Debug, ThisError)]
#[non_exhaustive]
pub enum MemMetaError {
    /// The read-write lock of this storage was poisoned due to an earlier panic.
    #[error("In-memory metadata store lock poisoned")]
    Poisoned,
}

impl From<MemMetaError> for MetaStorageError<MemMetaError> {
    fn from(err: MemMetaError) -> Self {
        MetaStorageError::Backend(err)
    }
}

impl<T> From<PoisonError<T>> for MetaStorageError<MemMetaError> {
    fn from(_: PoisonError<T>) -> Self {
        MemMetaError::Poisoned.into()
    }
}