sayiir-runtime 0.2.0

Execution runtime, checkpointing runner and distributed workers for Sayiir workflows
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
42
43

//! Module for workflow runners.
//!
//! A workflow runner is responsible for executing workflows.
//! Different implementations can provide different execution strategies,
//! such as in-process execution, distributed execution, or execution with
//! persistence and recovery.

use sayiir_core::codec::sealed;
use sayiir_core::codec::{Codec, EnvelopeCodec};
use sayiir_core::workflow::{Workflow, WorkflowStatus};
use std::future::Future;

use crate::error::RuntimeError;

/// A trait for executing workflows.
///
/// Different implementations can provide different execution strategies,
/// such as in-process execution, distributed execution, or execution with
/// persistence and recovery.
///
/// Note: This trait uses `impl Future` which makes it non-object-safe.
/// If you need dynamic dispatch, wrap implementations in an enum.
pub trait WorkflowRunner: Send + Sync {
    /// Run a workflow with the given input.
    ///
    /// The input type must match the input type of the first task added via `then`.
    /// Returns the workflow execution status.
    fn run<'w, C, Input, M>(
        &self,
        workflow: &'w Workflow<C, Input, M>,
        input: Input,
    ) -> impl Future<Output = Result<WorkflowStatus, RuntimeError>> + Send + 'w
    where
        Input: Send + 'static,
        M: Send + Sync + 'static,
        C: Codec + EnvelopeCodec + sealed::EncodeValue<Input>;
}

pub mod distributed;
pub mod ext;
pub mod in_process;

pub use ext::WorkflowRunExt;