parallel_operator¶
Module that defines the RayOperator class
-
class
tasrif.processing_pipeline.parallel_operator.ParallelOperator(num_processes=1)¶ Interface specification of an operator that uses ray
-
__init__(num_processes=1)¶ Constructs a ray operator. Replaces _process with _process_ray
- Parameters
num_processes – int number of logical processes to use to process the operator
-
static
init_ray(num_cpus)¶ Initialized Ray cluster. If the cluster is already initialized, and the number of logical processes being used is different than num_cpus, restart the cluster with num_cpus
- Parameters
num_cpus – int number of logical processes to use to process the operator
-