yt.utilities.parallel_tools.io_runner module

A simple IO staging mechanism

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

Bases: yt.utilities.io_handler.BaseIOHandler

initialize_data()[source]
peek(grid, field)
pop(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

peek(grid, field)
pop(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]