Update metrics.py

This commit is contained in:
michplunkett
2025-03-14 22:45:20 -05:00
parent a59a916b7e
commit a7a5b16ae6

View File

@@ -38,7 +38,8 @@ DATABASE_METRICS_COUNTER = Counter(
async def redis_subscribe_worker_exceptions(redis_exceptions_channel: str):
# Subscribe to Redis channel and increment the counter for each exception with info on the exception and task
# Subscribe to Redis channel and increment the counter for each exception
# with info on the exception and task
Redis = get_redis()
PubSubExceptions = Redis.pubsub()
PubSubExceptions.subscribe(redis_exceptions_channel)