hatchet-sdk 0.2.8

This is an unofficial Rust SDK for Hatchet, a distributed, fault-tolerant task queue.
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

use thiserror::Error;

#[derive(Clone, Debug, Error)]
pub enum HatchetError {
    #[error("missing required environment variable \"{0}\"")]
    MissingEnvVar(String),
    #[error("token should have three parts")]
    InvalidTokenFormat,
    #[error("{0}")]
    Base64DecodeError(#[from] base64::DecodeError),
    #[error("Error decoding JSON: {0}")]
    JsonDecodeError(String),
    #[error("Error encoding JSON: {0}")]
    JsonEncode(String),
    #[error("Missing required field in JWT payload: {0}")]
    MissingTokenField(&'static str),
    #[error("Invalid authorization header in gRPC request: {0}")]
    InvalidAuthHeader(String),
    #[error("Unable to connect to gRPC server: {0}")]
    GrpcConnect(String),
    #[error("Response missing output")]
    MissingOutput,
    #[error("{0}")]
    WorkflowFailed(String),
    #[error("workflow cancelled")]
    WorkflowCancelled,
    #[error("invalid gRPC URI: {0}")]
    InvalidUri(String),
    #[error("no tasks found in workflow")]
    MissingTasks,
    #[error("{0}")]
    SystemTimeError(#[from] std::time::SystemTimeError),
    #[error("unrecognized action received: {0}")]
    UnrecognizedAction(String),
    #[error("task not found: {task_name}")]
    TaskNotFound { task_name: String },
    #[error("Parent task not found: {parent_step_name}")]
    ParentTaskNotFound { parent_step_name: String },
    #[error("Invalid gRPC address: {0}")]
    InvalidGrpcAddress(String),
    #[error("Invalid TLS strategy: '{0}'. Valid options are 'none' or 'tls'")]
    InvalidTlsStrategy(String),
    #[error("gRPC request returned error: {0}")]
    GrpcErrorStatus(String),
    #[error("Error installing default crypto provider")]
    CryptoProvider,
    #[error("{0}")]
    RestApiError(String),
    #[error("Invalid cron expression: {0}")]
    InvalidCronExpression(String),
    #[error("Error sending message to dispatcher: {0}")]
    DispatchError(String),
    #[error("Error sending stream event: {0}")]
    StreamError(String),
    #[error("Internal error: {0}")]
    InternalError(String),
}

impl HatchetError {
    pub(crate) fn from_rest<E: std::fmt::Display>(error: E) -> Self {
        Self::RestApiError(error.to_string())
    }
}