validators

pyrosetta.distributed.cluster.validators._validate_clients_indices(clients_indices: Any, _protocols: List[Callable[[...], Any]], _clients_dict_keys: List[int]) → Optional[NoReturn]

Validate the clients_indices keyword argument parameter.

pyrosetta.distributed.cluster.validators._validate_resources(resources: Any, _protocols: List[Callable[[...], Any]]) → Optional[NoReturn]

Validate the resources keyword argument parameter.

pyrosetta.distributed.cluster.validators._validate_priorities(priorities: Any, _protocols: List[Callable[[...], Any]]) → Optional[NoReturn]

Validate the priorities keyword argument parameter.

pyrosetta.distributed.cluster.validators._validate_retries(retries: Any, _protocols: List[Callable[[...], Any]]) → Optional[NoReturn]

Validate the retries keyword argument parameter.

pyrosetta.distributed.cluster.validators._validate_scorefile_name(self, attribute: str, value: Any) → Optional[NoReturn]

pyrosetta.distributed.cluster.validators._validate_output_init_file(self, attribute: str, value: Any) → Optional[NoReturn]

pyrosetta.distributed.cluster.validators._validate_logging_address(self, attribute: str, value: Any) → Optional[NoReturn]

pyrosetta.distributed.cluster.validators._validate_dirs(self, attribute: str, value: Any) → Optional[NoReturn]

Validate the output, logging, and decoy directories.

pyrosetta.distributed.cluster.validators._validate_dir(self, attribute: str, value: str) → Optional[NoReturn]

Validate the scratch directory.

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

Validate that integers are greater than or equal to 1.

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

Optionally validate that iterables have at least one object.

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

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]) → Optional[NoReturn]

Validate that floats are greater than or equal to 0.0

pyrosetta.distributed.cluster.validators._validate_protocols_seeds_decoy_ids(protocols: List[Union[Callable[[...], Any], Iterable[Any]]], seeds: List[str], decoy_ids: List[int]) → Union[List[Union[Callable[[...], Any], Iterable[Any]]], NoReturn]

Validate that the user-provided PyRosetta protocols and PyRosettaCluster seeds and decoy_ids attributes have the same size.

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

Validate that the compute instance (distributed worker) ResidueType set equals client instance (local host) ResidueType set.

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

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.