pyrosetta.distributed Namespace Reference

Namespaces
	cluster
	dask
	docs
	io
	packed_pose
	tasks
	utility
	viewer

Functions
def	_normflags (flags)
def	with_lock (func)
def	maybe_init (**kwargs)
def	requires_init (func)
def	init (options=None, **kwargs)

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

Function Documentation

_normflags()

def pyrosetta.distributed._normflags (   flags )

private

Normalize list/tuple/set/dict/str of flags into str.

References join(), and binder.split().

Referenced by pyrosetta.distributed.cluster.io.IO._get_instance_and_metadata(), pyrosetta.distributed.cluster.base.TaskBase._setup_seed(), pyrosetta.distributed.maybe_init(), pyrosetta.tests.distributed.test_smoke.SmokeTestDistributed.test_score_smoke_test(), and pyrosetta.distributed.dask.worker_extra().

init()

def pyrosetta.distributed.init	(		options = None,
		**	kwargs
	)

Initialize PyRosetta with reformatted command line options.

References pyrosetta.distributed.maybe_init().

Referenced by pyrosetta.distributed.cluster.initialization._maybe_init_master(), pyrosetta.distributed.dask.init_notebook(), pyrosetta.tests.distributed.cluster.skip_command_line_test.BasicTest.test_basic(), pyrosetta.tests.distributed.cluster.test_logging.LoggingTest.test_logging(), pyrosetta.tests.distributed.cluster.test_reproducibility.TestReproducibilityMulti.test_reproducibility_from_reproduce(), pyrosetta.tests.distributed.cluster.test_reproducibility.TestReproducibility.test_reproducibility_minimizer_nstruct(), pyrosetta.tests.distributed.cluster.test_reproducibility.TestReproducibility.test_reproducibility_packer_nstruct(), pyrosetta.tests.distributed.cluster.test_reproducibility.TestReproducibilityMulti.test_reproducibility_packer_nstruct_multi(), pyrosetta.tests.distributed.cluster.test_reproducibility.TestReproducibilityMulti.test_reproducibility_packer_nstruct_multi_decoy_ids(), pyrosetta.tests.distributed.cluster.test_reproducibility.TestReproducibility.test_reproducibility_packer_separate(), pyrosetta.tests.distributed.cluster.test_smoke.SaveAllTest.test_save_all(), pyrosetta.tests.distributed.cluster.test_smoke.SaveAllTest.test_save_all_dry_run(), pyrosetta.tests.distributed.test_smoke.SmokeTestDistributed.test_score_smoke_test(), pyrosetta.tests.distributed.cluster.test_smoke.SmokeTest.test_smoke(), pyrosetta.tests.distributed.cluster.test_smoke.SmokeTestMulti.test_smoke_multi(), and pyrosetta.tests.distributed.cluster.test_smoke.SmokeTestMulti.test_smoke_multi_from_instance().

maybe_init()

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().

requires_init()

def pyrosetta.distributed.requires_init

(

func

)

Asserting that pyrosetta is initialized before function execution.

References pyrosetta.distributed.maybe_init().

with_lock()

def pyrosetta.distributed.with_lock

(

func

)

Function decorator that protects access to rosetta internals.

References join().

Variable Documentation

__all__

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

private

_access_lock

pyrosetta.distributed._access_lock = threading.RLock()

private

_logger

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

private