multiprocessing

pyrosetta.distributed.cluster.multiprocessing._maybe_delay(dt: float, max_delay_time: Union[float, int], logger: Logger) → None

Maybe delay the user-provided PyRosetta protocol result(s).

pyrosetta.distributed.cluster.multiprocessing.user_protocol(packed_pose: PackedPose, protocol: Callable[[...], Any], ignore_errors: bool, **kwargs: Dict[Any, Any]) → Any

Run the user-provided PyRosetta protocol.

pyrosetta.distributed.cluster.multiprocessing.run_protocol(protocol_name: str, protocol: Callable[[...], Any], packed_pose: PackedPose, datetime_format: str, norm_task_options: bool, ignore_errors: bool, protocols_key: str, decoy_ids: List[int], serializer: S, **kwargs: Dict[Any, Any]) → List[Tuple[bytes, bytes]]

Parse the user-provided PyRosetta protocol results.

pyrosetta.distributed.cluster.multiprocessing.get_target_results_kwargs(q: Q, p: P, compressed_kwargs: bytes, protocol_name: str, timeout: Union[float, int], ignore_errors: bool) → List[Tuple[Optional[bytes], bytes]]

Get and parse the billiard subprocess results.

pyrosetta.distributed.cluster.multiprocessing.target(protocol_name: str, compressed_protocol: bytes, compressed_packed_pose: bytes, compressed_kwargs: bytes, q: Q, logging_level: str, socket_listener_address: Tuple[str, int], datetime_format: str, norm_task_options: bool, ignore_errors: bool, protocols_key: str, decoy_ids: List[int], instance_id: str, prk: bytes, compression: Optional[Union[str, bool]], with_nonce: bool, client_residue_type_set: AbstractSet[str], client_repr: str, masked_key: Optional[bytes], task_id: str, **pyrosetta_init_kwargs: Dict[str, Any]) → None

A wrapper function for a user-provided PyRosetta protocol.

pyrosetta.distributed.cluster.multiprocessing.user_spawn_thread(protocol_name: str, compressed_protocol: bytes, compressed_packed_pose: bytes, compressed_kwargs: bytes, pyrosetta_init_kwargs: Dict[str, Any], client_repr: str, extra_args: Dict[str, Any], masked_key: bytes, task_id: str) → List[Tuple[Optional[Union[PackedPose, bytes]], Union[Dict[Any, Any], bytes]]]

Generic worker task using the billiard multiprocessing module.