jamjet-worker 0.3.1

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

//! JamJet Worker
//!
//! Workers are separate processes (or tasks) that:
//! - Pull work items from the queue
//! - Acquire leases (preventing duplicate execution)
//! - Execute node logic (model calls, tool calls, Python functions, MCP, A2A)
//! - Emit heartbeats to renew leases
//! - Report results back via the state backend

pub mod executor;
pub mod executors;
pub mod heartbeat;
pub mod pool;
pub mod worker;

pub use executor::{ExecutionResult, NodeExecutor};
pub use executors::{
    A2aTaskExecutor, AgentDiscoveryExecutor, EvalExecutor, McpToolExecutor, ModelNodeExecutor,
};
pub use pool::{default_pool, WorkerGroupConfig, WorkerPool};
pub use worker::Worker;