workflow_graph_queue/
error.rs

1use thiserror::Error;
2
3#[derive(Debug, Error)]
4pub enum QueueError {
5    #[error("job not found: {0}")]
6    JobNotFound(String),
7    #[error("lease not found or expired: {0}")]
8    LeaseNotFound(String),
9    #[error("lease expired for job {0}")]
10    LeaseExpired(String),
11    #[error("workflow not found: {0}")]
12    WorkflowNotFound(String),
13    #[error("internal error: {0}")]
14    Internal(String),
15}
16
17#[derive(Debug, Error)]
18pub enum ArtifactError {
19    #[error("artifact not found for {0}/{1}")]
20    NotFound(String, String),
21    #[error("internal error: {0}")]
22    Internal(String),
23}
24
25#[derive(Debug, Error)]
26pub enum LogError {
27    #[error("internal error: {0}")]
28    Internal(String),
29}
30
31#[derive(Debug, Error)]
32pub enum RegistryError {
33    #[error("worker not found: {0}")]
34    WorkerNotFound(String),
35    #[error("internal error: {0}")]
36    Internal(String),
37}
38
39#[derive(Debug, Error)]
40pub enum SchedulerError {
41    #[error("workflow not found: {0}")]
42    WorkflowNotFound(String),
43    #[error("queue error: {0}")]
44    Queue(#[from] QueueError),
45    #[error("artifact error: {0}")]
46    Artifact(#[from] ArtifactError),
47    #[error("internal error: {0}")]
48    Internal(String),
49}
workflow_graph_queue/error.rs

workflow_graph_queue/
error.rs
