Skip to content
This repository was archived by the owner on Sep 16, 2024. It is now read-only.

Commit 1de0488

Browse files
authored
Gracefully handle Redis Exceptions in queue monitor (#5)
1 parent f3574b7 commit 1de0488

File tree

2 files changed

+15
-3
lines changed

2 files changed

+15
-3
lines changed

setup.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
setup (
44
name = 'rpq',
5-
version = '1.0.4',
5+
version = '1.0.5',
66
description = 'Simple Redis work queue with added features (priorities, pop multiple items at once)',
77
long_description = 'README.md',
88
author = 'Gabriel Bordeaux',

src/queue_monitor.py

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,13 @@ def main():
7070
global t, r
7171

7272
# Redis connection
73-
r = redis.StrictRedis(host = args.host, port = args.port, db = args.dbnum, password = args.auth)
73+
try:
74+
r = redis.StrictRedis(host = args.host, port = args.port, db = args.dbnum, password = args.auth)
75+
except Exception as e:
76+
import sys
77+
78+
print('Redis error: %s' % (e))
79+
sys.exit()
7480

7581
# Sort groups
7682
sortGroups = setSortGroups(args.sort_groups);
@@ -84,7 +90,13 @@ def main():
8490
setColumnAlign(titles);
8591

8692
# Get queues
87-
queueNames = r.smembers('rpq|names')
93+
try:
94+
queueNames = r.smembers('rpq|names')
95+
except Exception as e:
96+
import sys
97+
98+
print('Redis error: %s' % (e))
99+
sys.exit()
88100

89101
# Add a row par queue
90102
for queueName in sorted(queueNames):

0 commit comments

Comments
 (0)