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//!
7//! Python filters execute in a **child subprocess** — the GIL is completely
8//! isolated from Rust/Tokio threads. No PyO3, no segfaults.
9
10pub mod detect;
11pub mod env_manager;
12pub mod protocol;
13pub mod python_process;
14pub mod server;
15pub mod worker;
16pub mod ws_transport;
17
18pub use detect::ResourceLimits;
19pub use env_manager::EnvManager;
20pub use protocol::*;
21pub use python_process::{PythonProcess, SubprocessFilter};
22pub use server::{
23 serve_worker, serve_worker_authenticated, worker_router, worker_router_authenticated,
24};
25pub use worker::Worker;
26pub use ws_transport::WsTransport;