multiprocessing¶
- pyrosetta.distributed.cluster.multiprocessing._maybe_delay(dt: float, max_delay_time: Union[float, int], logger: Logger) None¶
Maybe delay the Dask worker result.
- pyrosetta.distributed.cluster.multiprocessing.user_protocol(packed_pose: PackedPose, protocol: Callable[[...], Union[Pose, PackedPose, Dict[str, Any], None, List[Optional[Union[Pose, PackedPose, Dict[str, Any]]]], Tuple[Optional[Union[Pose, PackedPose, Dict[str, Any]]], ...], Generator[Optional[Union[Pose, PackedPose, Dict[str, Any]]], None, None]]], ignore_errors: bool, kwargs: Dict[str, Any]) Any¶
Run the user-defined PyRosetta protocol.
- pyrosetta.distributed.cluster.multiprocessing.run_protocol(protocol_name: str, protocol: Callable[[...], Union[Pose, PackedPose, Dict[str, Any], None, List[Optional[Union[Pose, PackedPose, Dict[str, Any]]]], Tuple[Optional[Union[Pose, PackedPose, Dict[str, Any]]], ...], Generator[Optional[Union[Pose, PackedPose, Dict[str, Any]]], None, None]]], packed_pose: PackedPose, datetime_format: str, norm_task_options: bool, ignore_errors: bool, protocols_key: str, decoy_ids: List[int], serializer: Serialization, kwargs: Dict[str, Any]) List[Tuple[bytes, bytes]]¶
Parse the user-defined PyRosetta protocol results.
- pyrosetta.distributed.cluster.multiprocessing.get_target_results_kwargs(q: Queue, p: Process, 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: Queue, 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: Set[str], client_repr: str, masked_key: Optional[bytes], task_id: str, **pyrosetta_init_kwargs: Any) None¶
A wrapper function for a user-defined PyRosetta protocol.