Skip to content

Commit

Permalink
Merge pull request #212 from danihodovic/add-redis-tls-to-queue
Browse files Browse the repository at this point in the history
fix: Add redis with TLS connection to transports
  • Loading branch information
adinhodovic authored Jan 20, 2023
2 parents 1c7f7f8 + 733bfa9 commit c04a421
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/exporter.py
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,7 @@ def __init__(self, buckets=None):
def track_queue_metrics(self):
with self.app.connection() as connection: # type: ignore
transport = connection.info()["transport"]
acceptable_transports = ["redis", "amqp", "memory"]
acceptable_transports = ["redis", "rediss", "amqp", "memory"]
if transport not in acceptable_transports:
logger.debug(
f"Queue length tracking is only implemented for {acceptable_transports}"
Expand All @@ -125,7 +125,7 @@ def track_queue_metrics(self):
queue_name=q
).set(l)
for queue in self.queue_cache:
if transport == "redis":
if transport in ["redis", "rediss"]:
queue_length = redis_queue_length(connection, queue)
track_length(queue, queue_length)
elif transport in ["amqp", "memory"]:
Expand Down

0 comments on commit c04a421

Please sign in to comment.