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

use hatchet_sdk::{Context, EmptyModel, Hatchet, Runnable, anyhow, tokio};
use thiserror::Error;

#[derive(Error, Debug)]
pub enum MyCustomError {
    #[error("Task failed. Start worker with RUST_BACKTRACE=1 to see backtrace")]
    TaskFailed,
}

pub async fn create_error_task() -> hatchet_sdk::Task<EmptyModel, EmptyModel> {
    let hatchet = Hatchet::from_env().await.unwrap();
    hatchet
        .task(
            "error-task",
            async move |_input: EmptyModel, _ctx: Context| -> anyhow::Result<EmptyModel> {
                Err(MyCustomError::TaskFailed)?
            },
        )
        .build()
        .unwrap()
}

#[tokio::main]
#[allow(dead_code)]
async fn main() {
    dotenvy::dotenv().ok();
    let error_task = create_error_task().await;
    match error_task.run(&EmptyModel, None).await {
        Ok(_) => (),
        Err(error) => {
            println!("Error: {}", error);
        }
    };
}