Struct ProcessAllocator

pub struct ProcessAllocator { /* private fields */ }

An allocator that allocates procs by executing managed (local) processes. ProcessAllocator is configured with a [Command] (template) to spawn external processes. These processes must invoke [hyperactor_mesh::bootstrap] or [hyperactor_mesh::bootstrap_or_die], which is responsible for coordinating with the allocator.

The process allocator tees the stdout and stderr of each proc to the parent process.

Implementations

impl ProcessAllocator

pub fn new(cmd: Command) -> Self

Create a new allocator using the provided command (template). The command is used to spawn child processes that host procs. The binary should yield control to [hyperactor_mesh::bootstrap] or [hyperactor_mesh::bootstrap_or_die] or after initialization.

Trait Implementations

impl Allocator for ProcessAllocator

type Alloc = ProcessAlloc

The type of Alloc produced by this allocator.

fn allocate<'life0, 'async_trait>( &'life0 mut self, spec: AllocSpec, ) -> Pin<Box<dyn Future<Output = Result<ProcessAlloc, AllocatorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Create a new allocation. The allocation itself is generally returned immediately (after validating parameters, etc.); the caller is expected to respond to allocation events as the underlying procs are incrementally allocated.