cars.orchestrator.cluster.sequential_cluster

Contains functions for sequential cluster

Module Contents

Classes

SequentialCluster

SequentialCluster

class cars.orchestrator.cluster.sequential_cluster.SequentialCluster(conf_cluster, out_dir, launch_worker=True)

Bases: cars.orchestrator.cluster.abstract_cluster.AbstractCluster

SequentialCluster

check_conf(conf)

Check configuration

Parameters

conf (dict) – configuration to check

Returns

overloaded configuration

Return type

dict

get_delayed_type()

Get delayed type

cleanup()

Cleanup cluster

create_task_wrapped(func, nout=2)

Create task

Parameters

• func – function

• nout – number of outputs

start_tasks(task_list)

Start all tasks

Parameters

task_list – task list

scatter(data, broadcast=True)

Distribute data through workers

Parameters

data – task data

future_iterator(future_list, timeout=None)

Start all tasks

Parameters

future_list – future_list list