fastvideo.v1.worker.multiproc_executor

fastvideo.v1.worker.multiproc_executor#

Module Contents#

Classes#

MultiprocExecutor

Data#

logger

API#

class fastvideo.v1.worker.multiproc_executor.MultiprocExecutor(fastvideo_args: fastvideo.v1.fastvideo_args.FastVideoArgs)[source]#

Bases: fastvideo.v1.worker.executor.Executor

collective_rpc(method: str | collections.abc.Callable, timeout: float | None = None, args: tuple = (), kwargs: dict | None = None) → list[Any][source]#
execute_forward(forward_batch: fastvideo.v1.pipelines.pipeline_batch_info.ForwardBatch, fastvideo_args: fastvideo.v1.fastvideo_args.FastVideoArgs) → fastvideo.v1.pipelines.pipeline_batch_info.ForwardBatch[source]#
set_lora_adapter(lora_nickname: str, lora_path: str | None = None) → None[source]#
shutdown() → None[source]#

Properly shut down the executor and its workers

fastvideo.v1.worker.multiproc_executor.logger[source]#

‘init_logger(…)’

Contents