o
    tBh,                     @   s8   d dl Zd dlmZmZ ddlmZ G dd deZdS )    N)SyncManagerState   )LokyProcessc                   @   s   e Zd ZdddZdS )LokyManagerN c              	   C   s   | j jtjks	J |durt|dstdtjdd\}}tt	| j
| j| jt| j| j|||fd| _ddd	 | jjD }t	| jd
 | | j_| j  |  | | _|  tj| j _tjj| t	| j| j| j| j| j | jfdd| _dS )z.Spawn a server process for this manager objectN__call__zinitializer must be a callableF)duplex)targetargs:c                 s   s    | ]}t |V  qd S )N)str).0ir   r   }/var/www/html/riverr-enterprise-integrations-main/venv/lib/python3.10/site-packages/joblib/externals/loky/backend/managers.py	<genexpr>#   s    z$LokyManager.start.<locals>.<genexpr>-r   )r   exitpriority)_statevaluer   INITIALhasattr	TypeErrormpPipeProcesstype_run_server	_registry_addressbytes_authkey_serializer_processjoin	_identity__name__namestartcloserecvSTARTEDutilFinalize_finalize_manager_Clientshutdown)selfinitializerinitargsreaderwriteridentr   r   r   r(      s4   




zLokyManager.start)Nr   )r&   
__module____qualname__r(   r   r   r   r   r      s    r   )	multiprocessingr   multiprocessing.managersr   r   processr   r   r   r   r   r   r   <module>   s   