|
| None | pyrosetta.distributed.cluster.multiprocessing._maybe_delay (float dt, Union[float, int] max_delay_time, logging.Logger logger) |
| |
| Any | pyrosetta.distributed.cluster.multiprocessing.user_protocol (PackedPose packed_pose, Callable[..., Any] protocol, bool ignore_errors, **Dict[Any, Any] kwargs) |
| |
| List[Tuple[bytes, bytes]] | pyrosetta.distributed.cluster.multiprocessing.run_protocol (str protocol_name, Callable[..., Any] protocol, PackedPose packed_pose, str datetime_format, bool ignore_errors, str protocols_key, List[int] decoy_ids, S serializer, **Dict[Any, Any] kwargs) |
| |
| List[Tuple[Optional[bytes], bytes]] | pyrosetta.distributed.cluster.multiprocessing.get_target_results_kwargs (Q q, P p, bytes compressed_kwargs, str protocol_name, Union[float, int] timeout, bool ignore_errors) |
| |
| None | pyrosetta.distributed.cluster.multiprocessing.target (str protocol_name, bytes compressed_protocol, bytes compressed_packed_pose, bytes compressed_kwargs, Q q, str logging_level, Tuple[str, int] socket_listener_address, str datetime_format, bool ignore_errors, str protocols_key, List[int] decoy_ids, Optional[Union[str, bool]] compression, AbstractSet[str] client_residue_type_set, str client_repr, Optional[bytes] masked_key, str task_id, **Dict[str, Any] pyrosetta_init_kwargs) |
| |
| List[Tuple[Optional[Union[PackedPose, bytes]], Union[Dict[Any, Any], bytes]]] | pyrosetta.distributed.cluster.multiprocessing.user_spawn_thread (str protocol_name, bytes compressed_protocol, bytes compressed_packed_pose, bytes compressed_kwargs, Dict[str, Any] pyrosetta_init_kwargs, str client_repr, Dict[str, Any] extra_args, bytes masked_key, str task_id) |
| |
