actflow 0.1.6

A lightweight, event-driven workflow engine written in 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
34
35
36
37
38
39
40
41

use std::sync::Arc;

use async_trait::async_trait;
use serde::{Deserialize, Serialize};
use serde_json::json;

use crate::{
    Result,
    common::Vars,
    runtime::Context,
    workflow::{actions::ActionType, node::NodeId},
};

use super::{Action, ActionOutput};

#[derive(Serialize, Deserialize, Debug, Clone)]
pub struct EndAction;

#[async_trait]
#[typetag::serde]
impl Action for EndAction {
    fn create(_: serde_json::Value) -> Result<Self> {
        Ok(EndAction)
    }

    fn schema() -> serde_json::Value {
        json!({})
    }

    fn action_type(&self) -> ActionType {
        ActionType::End
    }

    async fn run(
        &self,
        _: Arc<Context>,
        _: NodeId,
    ) -> Result<ActionOutput> {
        Ok(ActionOutput::success(Vars::new()))
    }
}