
    0Fie                        d dl mZ d dlmZmZmZmZmZmZm	Z	m
Z
mZ d dlmZmZmZmZ d dlmZ d dlmZmZ d Z e             dS )    )annotations)	get_address_hostget_address_host_portget_local_address_fornormalize_addressparse_addressparse_host_portresolve_addressunparse_addressunparse_host_port)CommCommClosedErrorconnectlisten)backends)get_tcp_server_addressget_tcp_server_addressesc                    dd l } ddlm}m} | j                            d          }|dk    r?ddlm} |                                t          d<   |	                                t          d<   nW|dk    r?dd	lm
} |                                t          d<   |	                                t          d<   nt          d
|           	 ddlm} d S # t          $ r Y d S w xY w)Nr   )inprocwszdistributed.comm.tcp.backendasyncio)asyncio_tcptcptlstornado)r   zOExpected `distributed.comm.tcp.backend` to be in `('asyncio', 'tornado')`, got )ucx)dask.configdistributed.commr   r   configgetr   
TCPBackendr   
TLSBackendr   
ValueErrorr   ImportError)daskr   r   tcp_backendr   r   r   s          9lib/python3.11/site-packages/distributed/comm/__init__.py_register_transportsr(      s+   +++++++++//"@AAKi000000%0022%0022			!	!((((((..**..**. +. .
 
 	

((((((((   s   C 
CCN)
__future__r   distributed.comm.addressingr   r   r   r   r   r	   r
   r   r   distributed.comm.corer   r   r   r   distributed.comm.registryr   distributed.comm.utilsr   r   r(        r'   <module>r0      s    " " " " " "
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 I H H H H H H H H H H H . . . . . . S S S S S S S S  :       r/   