File tree 2 files changed +11
-8
lines changed 2 files changed +11
-8
lines changed Original file line number Diff line number Diff line change @@ -5,15 +5,17 @@ def get_queue_index(name='default'):
5
5
"""
6
6
Returns the position of Queue for the named queue in QUEUES_LIST
7
7
"""
8
- queue_index = None
9
8
connection = get_connection (name )
10
- connection_kwargs = connection . connection_pool . connection_kwargs
9
+
11
10
for i in range (0 , 100 ):
12
11
try :
13
12
q = get_queue_by_index (i )
14
13
except AttributeError :
15
14
continue
16
- if q .name == name and q .connection .connection_pool .connection_kwargs == connection_kwargs :
17
- queue_index = i
18
- break
19
- return queue_index
15
+ if q .name == name :
16
+ # assert that the connection is correct
17
+ assert q .connection .connection_pool .connection_kwargs == connection .connection_pool .connection_kwargs
18
+
19
+ return i
20
+
21
+ return None
Original file line number Diff line number Diff line change @@ -67,9 +67,10 @@ def get_statistics(run_maintenance_tasks=False):
67
67
else :
68
68
oldest_job_timestamp = "-"
69
69
70
- # parse_class and connection_pool are not needed and not JSON serializable
71
- connection_kwargs .pop ('parser_class' , None )
70
+ # remove unneeded properties which are not serializable in JSON
72
71
connection_kwargs .pop ('connection_pool' , None )
72
+ connection_kwargs .pop ('parser_class' , None )
73
+ connection_kwargs .pop ('retry' , None )
73
74
74
75
queue_data = {
75
76
'name' : queue .name ,
You can’t perform that action at this time.
0 commit comments