jamjet-worker 0.3.2

JamJet worker process — task execution, heartbeat, lease renewal
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

//! Node executors — one per node kind.
//! Each executor takes a WorkItem, runs the node logic, and returns a result.

use jamjet_state::backend::WorkItem;
use serde_json::Value;

/// Channel sender for real-time streaming events from executors.
pub type StreamEventSender = tokio::sync::mpsc::Sender<Value>;

pub struct ExecutionResult {
    pub output: Value,
    pub state_patch: Value,
    pub duration_ms: u64,
    /// Telemetry: GenAI provider system (e.g. "anthropic", "openai"). None for non-model nodes.
    pub gen_ai_system: Option<String>,
    /// Telemetry: model name used.
    pub gen_ai_model: Option<String>,
    /// Telemetry: input tokens consumed.
    pub input_tokens: Option<u64>,
    /// Telemetry: output tokens generated.
    pub output_tokens: Option<u64>,
    /// Telemetry: finish reason (e.g. "stop", "length", "tool_calls").
    pub finish_reason: Option<String>,
}

/// Trait implemented by each node kind executor.
#[async_trait::async_trait]
pub trait NodeExecutor: Send + Sync {
    async fn execute(&self, item: &WorkItem) -> Result<ExecutionResult, String>;

    /// Execute with streaming event emission. Default delegates to `execute()`.
    async fn execute_streaming(
        &self,
        item: &WorkItem,
        _tx: StreamEventSender,
    ) -> Result<ExecutionResult, String> {
        self.execute(item).await
    }
}