multiprocess.multiproc_queue ============================ .. py:module:: multiprocess.multiproc_queue .. autoapi-nested-parse:: The client for the Multiprocess executor. Classes ------- .. autoapisummary:: multiprocess.multiproc_queue.MultiprocessQueue Module Contents --------------- .. py:class:: MultiprocessQueue(queue_id: int, queue_name: str, parameters: Dict) Bases: :py:obj:`jobmon.core.cluster_protocol.ClusterQueue` Implementation of the multiprocess executor queue, derived from ClusterQueue. Intialization of the multiprocess queue. Get the limits from the database in the client. .. py:method:: validate_resources(strict: bool = False, **kwargs: Union[str, int, float]) -> Tuple[bool, str] Ensure cores requested isn't more than available on that node. .. py:method:: coerce_resources(**kwargs: Union[str, int, float]) -> Dict Ensures that requested resources aren't greater than what's available. .. py:property:: queue_id :type: int Return the ID of the queue. .. py:property:: queue_name :type: str Return the name of the queue. .. py:property:: parameters :type: Dict Return the dictionary of parameters. .. py:property:: required_resources :type: List No required resources specified for dummy executor, return empty list.