fiftyone.core.map.process

module documentation

(source)

Multiprocessing utilities.

Class	`ProcessMapper`	Executes map_samples using multiprocessing.
Type Variable	`R`	Undocumented
Type Variable	`T`	Undocumented
Variable	`fov`	Undocumented
Function	`_init_worker`	Undocumented
Function	`_map_batch`	Undocumented

R = (source) ¶

Undocumented

Value

TypeVar('R')

T = (source) ¶

Undocumented

Value

TypeVar('T')

fov = (source) ¶

Undocumented

def _init_worker(dataset_name: str, view_stages: Any, map_fcn: bytes, batch_count: multiprocessing.Value | None, sample_count: multiprocessing.Value | None, queue: multiprocessing.Queue | None, cancel_event: multiprocessing.Event, save: bool, progress: bool, skip_failures: bool, lock: multiprocessing.RLock | None): (source) ¶

Undocumented

def _map_batch(args: tuple[int, int, fomb.SampleBatch]): (source) ¶

Undocumented