pyrosetta.distributed Namespace Reference

Namespaces
	dask
	docs
	io
	packed_pose
	tasks
	utility

Functions
def	with_lock
def	maybe_init
def	requires_init

Variables
tuple	_logger = logging.getLogger("pyrosetta.distributed")
list	__all__ = ["maybe_init", "requires_init", "with_lock"]
tuple	_access_lock = threading.RLock()

Function Documentation

def pyrosetta.distributed.maybe_init

(

kwargs

)

Call pyrosetta.init if not already initialized.

References pyrosetta.init().

Referenced by pyrosetta.distributed.dask.worker.dask_setup(), pyrosetta.distributed.dask.init_notebook(), and pyrosetta.distributed.requires_init().

def pyrosetta.distributed.requires_init

(

func

)

Asserting that pyrosetta is initialized before function execution.

References pyrosetta.distributed.maybe_init().

def pyrosetta.distributed.with_lock

(

func

)

Function decorator that protects access to rosetta internals.

References fmt.join().

Variable Documentation

list pyrosetta.distributed.__all__ = ["maybe_init", "requires_init", "with_lock"]

tuple pyrosetta.distributed._access_lock = threading.RLock()

tuple pyrosetta.distributed._logger = logging.getLogger("pyrosetta.distributed")