yt.utilities.parallel_tools.io_runner module

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

Bases: yt.utilities.io_handler.BaseIOHandler

initialize_data()[source]
io_iter(chunks, fields)
peek(grid, field)
preload(chunk, fields, max_size)
push(grid, field, data)
wait()[source]
class yt.utilities.parallel_tools.io_runner.IOHandlerRemote(ds, wg, pool)[source]

Bases: yt.utilities.io_handler.BaseIOHandler

io_iter(chunks, fields)
peek(grid, field)
preload(chunk, fields, 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]