o
    Á¿i   ã                   @   sd   d dl Z d dlmZ d dlmZ ddlmZ defdd„Z	de
eef fd	d
„Zdd„ Zdd„ ZdS )é    N)Úunwrap)Úwrapé   )Ú_wrap_submitÚreturnc                   C   s   dS )NÚ © r   r   r   úZ/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/contrib/internal/futures/patch.pyÚget_version	   s   r
   c                   C   s   ddiS )Núconcurrent.futures.threadÚ*r   r   r   r   r	   Ú_supported_versions   s   r   c                  C   s\   zt jd } W n ty   ddlm  m}  Y nw t| ddƒr"dS d| _t| j	j
tƒ dS )z+Enables Context Propagation between threadsr   r   NÚ__datadog_patchFT)ÚsysÚmodulesÚKeyErrorÚconcurrent.futures.threadÚfuturesÚthreadÚgetattrr   Ú_wÚThreadPoolExecutorÚsubmitr   ©r   r   r   r	   Úpatch   s   ÿr   c                  C   sL   zt jd } W n
 ty   Y dS w t| ddƒsdS d| _t| jjtƒ dS )z,Disables Context Propagation between threadsr   Nr   F)	r   r   r   r   r   Ú_ur   r   r   r   r   r   r	   Úunpatch!   s   ÿr   )r   Úddtrace.internal.wrappingr   r   r   r   Ú	threadingr   Ústrr
   Údictr   r   r   r   r   r   r	   Ú<module>   s    