Crate jamjet_worker 

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

Re-exports

pub use executor::ExecutionResult;

pub use executor::NodeExecutor;

pub use executors::A2aTaskExecutor;

pub use executors::AgentDiscoveryExecutor;

pub use executors::EvalExecutor;

pub use executors::McpToolExecutor;

pub use executors::ModelNodeExecutor;

pub use pool::default_pool;

pub use pool::WorkerGroupConfig;

pub use pool::WorkerPool;

pub use worker::Worker;

Modules

executor

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

executors

heartbeat

Worker heartbeat — periodically renews the lease on a claimed work item.

pool

Worker pool — manages a fleet of concurrent worker Tokio tasks.

worker