manager

GlasswallProcessManager

class GlasswallProcessManager()

__init__

def __init__(max_workers: Optional[int] = None,
             worker_timeout_seconds: Optional[float] = None,
             memory_limit_in_gib: Optional[float] = None)

__enter__

def __enter__()

__exit__

def __exit__(exc_type, exc_val, exc_tb)

queue_task

def queue_task(task: Task)

as_completed

def as_completed() -> Generator[TaskResult, None, None]

start_tasks

def start_tasks()

wait_for_completed_process

def wait_for_completed_process()

remove_completed_active_processes

def remove_completed_active_processes()

clean_task_results_queue

def clean_task_results_queue()