somatize-worker 0.2.26

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
27
28
29

//! 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`]).

pub mod coordinator;
pub mod coordinator_server;
pub mod detect;
pub mod env_manager;
pub mod protocol;
#[cfg(feature = "embedded-python")]
pub mod py_filter;
pub mod remote_executor;
pub mod server;
pub mod worker;

pub use coordinator::{WorkerRegistry, WorkerStatus};
pub use coordinator_server::{coordinator_router, serve_coordinator};
pub use detect::ResourceLimits;
pub use env_manager::EnvManager;
pub use protocol::*;
#[cfg(feature = "embedded-python")]
pub use py_filter::EmbeddedPyFilter;
pub use remote_executor::WsRemoteExecutor;
pub use server::{
    serve_worker, serve_worker_authenticated, worker_router, worker_router_authenticated,
};
pub use worker::Worker;