smol-workflow-engine 0.1.0

Rust implementation of the smol-workflows engine.
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

//! Typed JSON payloads stored in durable SQLite `*_json` columns.
//!
//! SQLite enforces `json_valid(...)`; these serde types are the application-level
//! schema used when creating and reading durable runner payloads.

use crate::metadata::WorkflowMetadata;
use serde::{Deserialize, Serialize};
use serde_json::Value;
use std::path::PathBuf;

#[derive(Debug, Clone, Deserialize, Serialize, PartialEq)]
#[serde(rename_all = "camelCase")]
pub struct LocalTaskParamsJSON {
    pub mode: DurableRunMode,
    pub script_path: PathBuf,
    pub args: Value,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub budget_total: Option<u64>,
}

#[derive(Debug, Clone, Deserialize, Serialize, PartialEq)]
#[serde(rename_all = "camelCase")]
pub struct WorkflowRunJSON {
    pub mode: DurableRunMode,
    pub script_path: PathBuf,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub metadata: Option<WorkflowMetadata>,
}

#[derive(Debug, Clone, Copy, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case")]
pub enum DurableRunMode {
    Local,
}

#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "camelCase")]
pub struct FailureReasonJSON {
    pub message: String,
}