ray_distributed_executor

Classes

fastvideo.worker.ray_distributed_executor.RayDistributedExecutor

RayDistributedExecutor(fastvideo_args: FastVideoArgs)

Bases: Executor

Ray-based distributed executor

Source code in fastvideo/worker/executor.py

def __init__(self, fastvideo_args: FastVideoArgs):
    self.fastvideo_args = fastvideo_args

    self._init_executor()

fastvideo.worker.ray_distributed_executor.RayWorkerMetaData dataclass

RayWorkerMetaData(worker: ActorHandle, created_rank: int, adjusted_rank: int = -1, ip: str = '')

Metadata for a Ray worker. The order of ray worker creation can be random, and we need to reset the rank after creating all workers.

Functions