yt.utilities.parallel_tools.task_queue module¶

class yt.utilities.parallel_tools.task_queue.TaskQueueNonRoot(tasks, comm, subcomm)[source]¶

Bases: object

finalize(vals=None)[source]¶

next()¶

run(callable)[source]¶

send_result(result)[source]¶

class yt.utilities.parallel_tools.task_queue.TaskQueueRoot(tasks, comm, njobs)[source]¶

Bases: TaskQueueNonRoot

assign_task(source_id)[source]¶

finalize(vals=None)¶

handle_assignment(status)[source]¶

insert_result(source_id, rstore)[source]¶

next()¶

run(func=None)[source]¶

send_result(result)¶

yt.utilities.parallel_tools.task_queue.dynamic_parallel_objects(tasks, njobs=0, storage=None, broadcast=True)[source]¶

yt.utilities.parallel_tools.task_queue.task_queue(func, tasks, njobs=0)[source]¶