cars.orchestrator.cluster.sequential_cluster

Contains functions for sequential cluster

Classes

SequentialCluster

SequentialCluster

Module Contents

class cars.orchestrator.cluster.sequential_cluster.SequentialCluster(conf_cluster, out_dir, log_dir, launch_worker=True)[source]

Bases: cars.orchestrator.cluster.abstract_cluster.AbstractCluster

SequentialCluster

profiling
out_dir
launch_worker = True
check_conf(conf)[source]

Check configuration

Parameters:

conf (dict) – configuration to check

Returns:

overloaded configuration

Return type:

dict

get_delayed_type()[source]

Get delayed type

cleanup(keep_shared_dir=False)[source]

Cleanup cluster

create_task_wrapped(func, nout=2)[source]

Create task

Parameters:

  • func – function

  • nout – number of outputs

start_tasks(task_list)[source]

Start all tasks

Parameters:

task_list – task list

scatter(data, broadcast=True)[source]

Distribute data through workers

Parameters:

data – task data

future_iterator(future_list, timeout=None)[source]

Start all tasks

Parameters:

future_list – future_list list