Skip to content

Commit 02ed26d

Browse files
authored
cast redis ports to int (#1591)
1 parent 2821be1 commit 02ed26d

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

‎elasticapm/instrumentation/packages/asyncio/aioredis.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,10 +96,10 @@ def _get_destination_info(connection):
9696
destination_info = {"service": {"name": "", "resource": "redis", "type": ""}}
9797

9898
if hasattr(connection, "_pool_or_conn"):
99-
destination_info["port"] = connection._pool_or_conn.address[1]
99+
destination_info["port"] = int(connection._pool_or_conn.address[1])
100100
destination_info["address"] = connection._pool_or_conn.address[0]
101101
else:
102-
destination_info["port"] = connection.address[1]
102+
destination_info["port"] = int(connection.address[1])
103103
destination_info["address"] = connection.address[0]
104104

105105
return destination_info

‎elasticapm/instrumentation/packages/redis.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ def call(self, module, method, wrapped, instance, args, kwargs):
9494
def get_destination_info(connection):
9595
destination_info = {}
9696
if hasattr(connection, "port"):
97-
destination_info["port"] = connection.port
97+
destination_info["port"] = int(connection.port)
9898
destination_info["address"] = connection.host
9999
elif hasattr(connection, "path"):
100100
destination_info["port"] = None

0 commit comments

Comments
 (0)