File tree 2 files changed +11
-7
lines changed
2 files changed +11
-7
lines changed Original file line number Diff line number Diff line change @@ -5,15 +5,18 @@ 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
9
connection_kwargs = connection .connection_pool .connection_kwargs
10
+
11
11
for i in range (0 , 100 ):
12
12
try :
13
13
q = get_queue_by_index (i )
14
14
except AttributeError :
15
15
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
16
+ if q .name == name :
17
+ # assert that the connection is correct
18
+ assert q .connection .connection_pool .connection_kwargs == connection_kwargs
19
+
20
+ return i
21
+
22
+ 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