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

cleanup()

Cleanup cluster

create_task(func, nout=1)

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)

Start all tasks

Parameters

future_list – future_list list