Master-worker module¶

Functions for master/worker task execution

class abed.run.Work(n_workers=1)[source]¶

Bases: object

get_chunk()[source]¶

get_next_item()[source]¶

isempty()[source]¶

property send_at_once¶

abed.run.copy_worker(local)[source]¶

abed.run.do_work(hsh, task, local=False)[source]¶

abed.run.master(all_work, worker_ranks, local=False)[source]¶

abed.run.mpi_start(task_dict, local=False)[source]¶

abed.run.mpi_start_local(task_dict)[source]¶

abed.run.mpi_start_remote(task_dict)[source]¶

abed.run.worker(task_dict, local=False)[source]¶