runner_q 0.6.4

Durable activity queue and worker system
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

use crate::storage::StorageError;
use thiserror::Error;

#[derive(Error, Debug)]
pub enum WorkerError {
    #[error("{0}")]
    CustomError(String),

    #[error("Activity queue error: {0}")]
    QueueError(String),

    #[error("Activity serialization error: {0}")]
    SerializationError(#[from] serde_json::Error),

    #[error("Activity execution timeout")]
    Timeout,

    #[error("Activity execution failed: {0}")]
    ExecutionError(String),

    #[error("Activity handler not found for activity type: {0}")]
    HandlerNotFound(String),

    #[error("Backend error: {0}")]
    BackendError(String),

    #[error("Database error: {0}")]
    DatabaseError(String),

    #[error("Configuration error: {0}")]
    ConfigError(String),

    #[error("Configuration error: {0}")]
    Configuration(String),

    #[error("Worker shutdown requested")]
    Shutdown,

    #[error("Worker is already running")]
    AlreadyRunning,

    #[error("Activity scheduling error: {0}")]
    SchedulingError(String),

    #[error("Duplicate activity detected: {0}")]
    DuplicateActivity(String),

    #[error("Idempotency key conflict: {0}")]
    IdempotencyConflict(String),

    #[error("Unknown error: {0}")]
    Unknown(String),
}

impl From<StorageError> for WorkerError {
    fn from(err: StorageError) -> Self {
        match err {
            StorageError::Unavailable(msg) => WorkerError::BackendError(msg),
            StorageError::Conflict(msg) => WorkerError::QueueError(msg),
            StorageError::NotFound(msg) => WorkerError::QueueError(msg),
            StorageError::Internal(msg) => WorkerError::QueueError(msg),
            StorageError::Serialization(msg) => WorkerError::QueueError(msg),
            StorageError::Configuration(msg) => WorkerError::ConfigError(msg),
            StorageError::Timeout(msg) => WorkerError::ExecutionError(msg),
            StorageError::DuplicateActivity(msg) => WorkerError::DuplicateActivity(msg),
            StorageError::IdempotencyConflict(msg) => WorkerError::IdempotencyConflict(msg),
        }
    }
}

impl WorkerError {
    pub fn is_retryable(&self) -> bool {
        match self {
            WorkerError::QueueError(_) => true,
            WorkerError::BackendError(_) => true,
            WorkerError::DatabaseError(_) => true,
            WorkerError::Timeout => true,
            WorkerError::ExecutionError(_) => true,
            WorkerError::SchedulingError(_) => true,
            _ => false,
        }
    }
}