U
    /e                     @  s~   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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                  C  s   dd l } ddlm}m} | jd}|dkrRddlm} | td< |	 td< n<|dkrdd	lm
} | td< |	 td< ntd
| zddlm} W n tk
r   Y nX d S )Nr   )inprocwszdistributed.comm.tcp.backendZasyncio)asyncio_tcptcpZtlsZtornado)r   zOExpected `distributed.comm.tcp.backend` to be in `('asyncio', 'tornado')`, got )ucx)Zdask.configZdistributed.commr   r   configgetr   Z
TCPBackendr   Z
TLSBackendr   
ValueErrorr   ImportError)Zdaskr   r   Ztcp_backendr   r   r    r   =/tmp/pip-unpacked-wheel-g426oqom/distributed/comm/__init__.py_register_transports   s$    r   N)
__future__r   Zdistributed.comm.addressingr   r   r   r   r   r   r	   r
   r   Zdistributed.comm.corer   r   r   r   Zdistributed.comm.registryr   Zdistributed.comm.utilsr   r   r   r   r   r   r   <module>   s   ,