yt.utilities.parallel_tools.task_queue module

Task queue in yt

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

Bases: object

finalize(vals=None)[source]
get_next()[source]
run(callable)[source]
send_result(result)[source]
class yt.utilities.parallel_tools.task_queue.TaskQueueRoot(tasks, comm, njobs)[source]

Bases: yt.utilities.parallel_tools.task_queue.TaskQueueNonRoot

assign_task(source_id)[source]
finalize(vals=None)
get_next()
handle_assignment(status)[source]
insert_result(source_id, result)[source]
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]