Root#

class nnodes.root.Root(cwd: str, data: dict, parent: nnodes.node.Node | None)#

Root node with job configuration.

async _ping()#

Periodically save to root.pickle.

_signal(*_)#

Requeue due to insufficient time.

async execute()#

Execute main task.

init(mpidir: Optional[str] = None)#

Restore state.

save()#

Save state from event loop.