dataflow-rs 2.0.3

A lightweight, rule-driven workflow engine for building powerful data processing pipelines and nanoservices in Rust. Extend it with your custom tasks to create robust, maintainable services.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use crate::engine::functions::FunctionConfig;
use serde::Deserialize;
use serde_json::Value;

/// Task represents a single processing unit within a workflow
#[derive(Clone, Debug, Deserialize)]
pub struct Task {
    pub id: String,
    pub name: String,
    pub description: Option<String>,
    #[serde(default = "default_condition")]
    pub condition: Value,
    #[serde(skip)]
    pub condition_index: Option<usize>,
    pub function: FunctionConfig,
    #[serde(default)]
    pub continue_on_error: bool,
}

fn default_condition() -> Value {
    Value::Bool(true)
}