Skip to main content

somatize_worker/
lib.rs

1//! Remote worker for distributed pipeline execution.
2//!
3//! Receives execution plans from a coordinator, runs them locally,
4//! and reports results. Each worker manages isolated Python environments
5//! ([`EnvManager`]) and communicates via WebSocket ([`protocol`]).
6
7pub mod coordinator;
8pub mod coordinator_server;
9pub mod detect;
10pub mod env_manager;
11pub mod protocol;
12pub mod remote_executor;
13pub mod server;
14pub mod worker;
15
16pub use coordinator::{WorkerRegistry, WorkerStatus};
17pub use coordinator_server::{coordinator_router, serve_coordinator};
18pub use detect::ResourceLimits;
19pub use env_manager::EnvManager;
20pub use protocol::*;
21pub use remote_executor::WsRemoteExecutor;
22pub use server::{
23    serve_worker, serve_worker_authenticated, worker_router, worker_router_authenticated,
24};
25pub use worker::Worker;