Zy Filemanager

📁 File Browser

Name	Size	Permissions	Actions
📁 __pycache__	DIR	0755	🗑️
📁 modules	DIR	0755	🗑️
📄 __init__.py (1,659 bytes)	1.62 KB	0644	✍️ ⬇️ 🗑️
📄 _async_common.py (4,056 bytes)	3.96 KB	0644	✍️ ⬇️ 🗑️
📄 _sync_common.py (3,796 bytes)	3.71 KB	0644	✍️ ⬇️ 🗑️
📄 consts.py (480 bytes)	480 B	0644	✍️ ⬇️ 🗑️
📄 rb.py (806 bytes)	806 B	0644	✍️ ⬇️ 🗑️
📄 redis.py (1,702 bytes)	1.66 KB	0644	✍️ ⬇️ 🗑️
📄 redis_cluster.py (3,554 bytes)	3.47 KB	0644	✍️ ⬇️ 🗑️
📄 redis_py_cluster_legacy.py (1,585 bytes)	1.55 KB	0644	✍️ ⬇️ 🗑️
📄 utils.py (4,005 bytes)	3.91 KB	0644	✍️ ⬇️ 🗑️

📤 Upload Files

Single File

Multiple Files

ZIP Extract

ZIP file will be deleted after extraction

➕ Create New

New Folder

New File

✍️ Editing: redis_py_cluster_legacy.py

            File: /opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/redis/redis_py_cluster_legacy.py

            Size: 1.55 KB | 
            Last Modified: 2025-12-03 14:34:44        

"""
Instrumentation for redis-py-cluster
The project redis-py-cluster is EOL and was integrated into redis-py starting from version 4.1.0 (Dec 26, 2021).

https://github.com/grokzen/redis-py-cluster
"""

from sentry_sdk.integrations.redis._sync_common import (
    patch_redis_client,
    patch_redis_pipeline,
)
from sentry_sdk.integrations.redis.modules.queries import _set_db_data
from sentry_sdk.integrations.redis.utils import _parse_rediscluster_command

def _patch_rediscluster():
    # type: () -> None
    try:
        import rediscluster  # type: ignore
    except ImportError:
        return

patch_redis_client(
        rediscluster.RedisCluster,
        is_cluster=True,
        set_db_data_fn=_set_db_data,
    )

# up to v1.3.6, __version__ attribute is a tuple
    # from v2.0.0, __version__ is a string and VERSION a tuple
    version = getattr(rediscluster, "VERSION", rediscluster.__version__)

# StrictRedisCluster was introduced in v0.2.0 and removed in v2.0.0
    # https://github.com/Grokzen/redis-py-cluster/blob/master/docs/release-notes.rst
    if (0, 2, 0) < version < (2, 0, 0):
        pipeline_cls = rediscluster.pipeline.StrictClusterPipeline
        patch_redis_client(
            rediscluster.StrictRedisCluster,
            is_cluster=True,
            set_db_data_fn=_set_db_data,
        )
    else:
        pipeline_cls = rediscluster.pipeline.ClusterPipeline

patch_redis_pipeline(
        pipeline_cls,
        is_cluster=True,
        get_command_args_fn=_parse_rediscluster_command,
        set_db_data_fn=_set_db_data,
    )

↩️ Back