zebflow 0.10.4

Reactive web automation platform — pipelines, templates, and real-time collaboration in a single binary.
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

//! Resident local execution backend.
//!
//! This backend represents the current monolithic execution shape where a pipeline run executes
//! inside the local process without a network hop.

use async_trait::async_trait;

use crate::infra::execution::backend::interface::{
    ExecutionBackend, ExecutionBackendKind, ExecutionError, ExecutionRequest,
};
use crate::infra::execution::handle::ExecutionHandle;

/// Whole-pipeline execution inside the local process.
#[derive(Debug, Clone, Default)]
pub struct ResidentLocalBackend;

#[async_trait]
impl ExecutionBackend for ResidentLocalBackend {
    fn id(&self) -> &'static str {
        "execution.resident_local"
    }

    fn kind(&self) -> ExecutionBackendKind {
        ExecutionBackendKind::ResidentLocal
    }

    async fn execute(&self, request: ExecutionRequest) -> Result<ExecutionHandle, ExecutionError> {
        let _ = request;
        Err(ExecutionError::new(
            "EXECUTION_BACKEND_UNWIRED",
            "resident local backend scaffold exists but is not wired to pipeline execution yet",
        ))
    }
}