validators

pyrosetta.distributed.cluster.validators._validate_clients_indices(clients_indices: Optional[Union[List[int], Tuple[int, ...]]], _protocols: Sized, _clients_dict_keys: List[int]) → None

Validate the clients_indices keyword argument value for the PyRosettaCluster.distribute method.

pyrosetta.distributed.cluster.validators._validate_resources(resources: Optional[Union[List[Optional[Dict[str, Union[float, int]]]], Tuple[Optional[Dict[str, Union[float, int]]], ...]]], _protocols: Sized) → None

Validate the resources keyword argument value for the PyRosettaCluster.distribute method.

pyrosetta.distributed.cluster.validators._validate_priorities(priorities: Optional[Union[List[int], Tuple[int, ...]]], _protocols: Sized) → None

Validate the priorities keyword argument value for the PyRosettaCluster.distribute method.

pyrosetta.distributed.cluster.validators._validate_retries(retries: Optional[Union[int, List[int], Tuple[int, ...]]], _protocols: Sized) → None

Validate the retries keyword argument value for the PyRosettaCluster.distribute method.

pyrosetta.distributed.cluster.validators._validate_scorefile_name(self, attribute: str, value: Any) → None

Validate the scorefile_name keyword argument value of PyRosettaCluster.

pyrosetta.distributed.cluster.validators._validate_output_init_file(self, attribute: str, value: Any) → None

Validate the output_init_file keyword argument value of PyRosettaCluster.

pyrosetta.distributed.cluster.validators._validate_logging_address(self, attribute: str, value: Any) → None

Validate the logging_address keyword argument value of PyRosettaCluster.

pyrosetta.distributed.cluster.validators._validate_dirs(self, attribute: str, value: Any) → None

Validate and make the output, logging, and decoy directories.

pyrosetta.distributed.cluster.validators._validate_dir(self, attribute: str, value: str) → None

Validate the scratch directory.

pyrosetta.distributed.cluster.validators._validate_int(self, attribute: str, value: int) → None

Validate that integers are greater than or equal to 1.

pyrosetta.distributed.cluster.validators._validate_min_len(self, attribute: str, value: Optional[List[Any]]) → None

Optionally validate that iterables have at least one object.

pyrosetta.distributed.cluster.validators._validate_max_task_replicas(self, attribute: str, value: Optional[int]) → None

Validate that the value is None or integers are greater than or equal to 0, and that Dask’s Active Memory Manager (AMM) policy is disabled.

pyrosetta.distributed.cluster.validators._validate_float(self, attribute: str, value: Union[float, int]) → None

Validate that float or int objects are greater than or equal to 0.

pyrosetta.distributed.cluster.validators._validate_protocols_seeds_decoy_ids(protocols: Sized, seeds: List[str], decoy_ids: List[int]) → Sized

Validate that the user-defined PyRosetta protocols, and the seeds and decoy_ids keyword argument values of PyRosettaCluster have the same size.

pyrosetta.distributed.cluster.validators._validate_residue_type_sets(_target_residue_type_set: Optional[Set[str]] = None, _client_residue_type_set: Optional[Set[str]] = None) → None

Validate that the ResidueType set in the billiard subprocess equals that in the head node process.

pyrosetta.distributed.cluster.validators._validate_task(task: Dict[Any, Any]) → None

Validate that a task does not contain disallowed or reserved keys/values.

pyrosetta.distributed.cluster.validators._validate_tasks(self, attribute: str, value: List[Dict[Any, Any]]) → None

Validate that tasks do not contain disallowed or reserved keys/values.

pyrosetta.distributed.cluster.validators._is_json_roundtrip_equal(obj: Any) → bool

Test if an object is equal after roundtrip JSON-serialization.