o
    ٰi                     @   sX   d Z ddlmZmZ ddlmZ ddlmZ er ddlmZm	Z	 dd
dZ
dddZdS )z>
Instrumentation for Redis

https://github.com/redis/redis-py
    )patch_redis_clientpatch_redis_pipeline)_set_db_data)TYPE_CHECKING)AnySequencecommandr   returnSequence[Any]c                 C   s   | d S )Nr    )r   r   r   W/home/ubuntu/.local/lib/python3.10/site-packages/sentry_sdk/integrations/redis/redis.py_get_redis_command_args   s   r   StrictRedisclientNc                 C   s   t | dtd t|jdttd z|j}W n	 ty   Y n	w t|dttd zdd l}W n
 ty7   Y d S w ddl	m
}m} ||jjjdtd ||jjjdttd d S )NF)
is_clusterset_db_data_fn)r   get_command_args_fnr   r   )patch_redis_async_clientpatch_redis_async_pipeline)r   )r   r   r   Pipeliner   StrictPipelineAttributeErrorredis.asyncioImportError+sentry_sdk.integrations.redis._async_commonr   r   asyncior   r   )r   r   strict_pipelineredisr   r   r   r   r   _patch_redis   sN   

r   )r   r   r	   r
   )r   r   r   r   r	   N)__doc__*sentry_sdk.integrations.redis._sync_commonr   r   -sentry_sdk.integrations.redis.modules.queriesr   typingr   r   r   r   r   r   r   r   r   <module>   s    
