apalis-workflow 0.1.0-rc.7

A flexible and composable task workflow engine for rust
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

use serde::{Deserialize, Serialize};

/// Context information for the current step in the workflow
#[derive(Debug, Clone)]
pub struct StepContext<Backend> {
    /// Index of the current step
    pub current_step: usize,
    /// Backend associated with the current step
    pub backend: Backend,
    /// Indicates if there is a next step
    pub has_next: bool,
}
impl<B> StepContext<B> {
    /// Creates a new StepContext
    pub fn new(backend: B, idx: usize, has_next: bool) -> Self {
        Self {
            current_step: idx,
            backend,
            has_next,
        }
    }
}

/// Metadata stored in each task for workflow processing
#[derive(Debug, Clone, Deserialize, Serialize, Default)]
pub struct WorkflowContext {
    /// Index of the step in the workflow
    pub step_index: usize,
    // / Additional fields can be added as needed
    // / name: String,
    // / version: String,
    // / parent_workflow_id: Option<String>,
}