Rosetta  2020.37
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Namespaces | Functions | Variables
pyrosetta.distributed Namespace Reference

Namespaces

 dask
 
 docs
 
 io
 
 packed_pose
 
 tasks
 
 utility
 
 viewer
 

Functions

def _normflags
 
def with_lock
 
def maybe_init
 
def requires_init
 
def init
 

Variables

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

Function Documentation

def pyrosetta.distributed._normflags (   flags)
private
def pyrosetta.distributed.init (   options = None,
  kwargs 
)
def pyrosetta.distributed.maybe_init (   kwargs)
Call pyrosetta.init with reformatted options and extra_options if not already initialized.

References pyrosetta._is_interactive(), pyrosetta.distributed._normflags(), and pyrosetta.init().

Referenced by pyrosetta.distributed.dask.worker.dask_setup(), pyrosetta.distributed.init(), 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__ = ["init", "maybe_init", "requires_init", "with_lock"]
tuple pyrosetta.distributed._access_lock = threading.RLock()
tuple pyrosetta.distributed._logger = logging.getLogger("pyrosetta.distributed")