utilities¶

class pyrosetta.distributed.cluster.utilities.SchedulerManager¶

Bases: Generic[G]

_setup_clients_dict() → Union[Dict[int, ClientType], NoReturn]¶

_get_cluster() → ClusterType¶: Given user input arguments, return the requested cluster instance.

_setup_clients_cluster_adaptive() → Tuple[Dict[int, ClientType], Optional[ClusterType], Optional[AdaptiveType]]¶: Given user input arguments, return the requested client, cluster, and adaptive instance.

_maybe_adapt(adaptive: Optional[AdaptiveType]) → None¶: Adjust max_workers.

_maybe_teardown(clients: Dict[int, ClientType], cluster: Optional[ClusterType]) → None¶: Teardown client and cluster.

_is_protocol = False¶