Struct Worker

struct Worker {
    id: usize,
    storage: Arc<Storage>,
    scheduler: Arc<Scheduler>,
    registry: Arc<NodeRegistry>,
    running: Arc<Mutex<bool>>,
    python_manager: Arc<Mutex<Option<Arc<PythonManager>>>>,
}

Fields

id: usize

storage: Arc<Storage>

scheduler: Arc<Scheduler>

registry: Arc<NodeRegistry>

running: Arc<Mutex<bool>>

python_manager: Arc<Mutex<Option<Arc<PythonManager>>>>

Implementations

impl Worker

fn new( id: usize, storage: Arc<Storage>, scheduler: Arc<Scheduler>, registry: Arc<NodeRegistry>, running: Arc<Mutex<bool>>, python_manager: Arc<Mutex<Option<Arc<PythonManager>>>>, ) -> Self

async fn run_worker_loop(&self)

async fn process_next_task(&self) -> Result<()>