somatize-worker 0.2.38

Worker daemon for distributed execution in the Soma runtime
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

//! Remote worker for distributed pipeline execution.
//!
//! Receives execution plans from a coordinator, runs them locally,
//! and reports results. Each worker manages isolated Python environments
//! ([`EnvManager`]) and communicates via WebSocket ([`protocol`]).
//!
//! Python filters execute in a **child subprocess** — the GIL is completely
//! isolated from Rust/Tokio threads. No PyO3, no segfaults.

pub mod detect;
pub mod env_manager;
pub mod protocol;
pub mod python_process;
pub mod server;
pub mod worker;
pub mod ws_transport;

pub use detect::ResourceLimits;
pub use env_manager::EnvManager;
pub use protocol::*;
pub use python_process::{PythonProcess, SubprocessFilter};
pub use server::{
    serve_worker, serve_worker_authenticated, worker_router, worker_router_authenticated,
};
pub use worker::Worker;
pub use ws_transport::WsTransport;