yt.utilities.parallel_tools.io_runner module¶

class yt.utilities.parallel_tools.io_runner.IOCommunicator(ds, wg, pool)[source]¶

Bases: BaseIOHandler

initialize_data()[source]¶

io_iter(chunks, fields: list[tuple[str, str]])¶

peek(grid, field)¶

preload(chunk, fields: list[tuple[str, str]], max_size)¶

push(grid, field, data)¶

wait()[source]¶

class yt.utilities.parallel_tools.io_runner.IOHandlerRemote(ds, wg, pool)[source]¶

Bases: BaseIOHandler

io_iter(chunks, fields: list[tuple[str, str]])¶

peek(grid, field)¶

preload(chunk, fields: list[tuple[str, str]], max_size)¶

push(grid, field, data)¶

terminate()[source]¶

yt.utilities.parallel_tools.io_runner.io_nodes(fn, n_io, n_work, func, *args, **kwargs)[source]¶

yt.utilities.parallel_tools.io_runner.remote_io(ds, wg, pool)[source]¶