Skip to content

Commit 57d1930

Browse files
committed
Rename _set_async_cluster_pipeline_db_data to _get_async_cluster_pipeline_db_data
1 parent 7275d57 commit 57d1930

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

sentry_sdk/integrations/redis/redis_cluster.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,8 +35,8 @@ def _get_async_cluster_db_data(async_redis_cluster_instance):
3535
return {}
3636

3737

38-
def _set_async_cluster_pipeline_db_data(span, async_redis_cluster_pipeline_instance):
39-
# type: (Span, AsyncClusterPipeline[Any]) -> dict[str, Any]
38+
def _get_async_cluster_pipeline_db_data(async_redis_cluster_pipeline_instance):
39+
# type: (AsyncClusterPipeline[Any]) -> dict[str, Any]
4040
with capture_internal_exceptions():
4141
return _get_async_cluster_db_data(
4242
# the AsyncClusterPipeline has always had a `_client` attr but it is private so potentially problematic and mypy
@@ -98,5 +98,5 @@ def _patch_redis_cluster():
9898
async_cluster.ClusterPipeline,
9999
is_cluster=True,
100100
get_command_args_fn=_parse_rediscluster_command,
101-
get_db_data_fn=_set_async_cluster_pipeline_db_data,
101+
get_db_data_fn=_get_async_cluster_pipeline_db_data,
102102
)

0 commit comments

Comments
 (0)