pyrosetta.distributed Namespace Reference

Namespaces
	cluster
	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

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

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

Referenced by pyrosetta.distributed.maybe_init(), pyrosetta.tests.distributed.test_smoke.SmokeTestDistributed.test_score_smoke_test(), and pyrosetta.distributed.dask.worker_extra().

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

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")