fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-08 09:08:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

Only show lock count when available and greater than zero

Browse Source
This commit is contained in:
Ilan Steemers
2015-09-19 15:42:35 +02:00
parent 54789a9597
commit 93a8f71157
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/brokers/__init__.py
+5
View File
@@ -29,6 +29,11 @@ class Broker(object):
""" """
pass pass
def lock_size(self):
"""
:return: the number of tasks currently awaiting acknowledgement
"""
def delete_queue(self): def delete_queue(self):
""" """
Deletes the queue from the broker Deletes the queue from the broker
django_q/monitor.py
+3 -2
View File
@@ -83,8 +83,9 @@ def monitor(run_once=False, broker=None):
# bottom bar # bottom bar
i += 1 i += 1
queue_size = broker.queue_size() queue_size = broker.queue_size()
if hasattr(broker, 'lock_size'): lock_size = broker.lock_size()
queue_size = '{}({})'.format(queue_size, broker.lock_size()) if lock_size:
queue_size = '{}({})'.format(queue_size, lock_size)
print(term.move(i, 0) + term.white_on_cyan(term.center(broker.info(), width=col_width * 2))) print(term.move(i, 0) + term.white_on_cyan(term.center(broker.info(), width=col_width * 2)))
print(term.move(i, 2 * col_width) + term.black_on_cyan(term.center(_('Queued'), width=col_width))) print(term.move(i, 2 * col_width) + term.black_on_cyan(term.center(_('Queued'), width=col_width)))
print(term.move(i, 3 * col_width) + term.white_on_cyan(term.center(queue_size, width=col_width))) print(term.move(i, 3 * col_width) + term.white_on_cyan(term.center(queue_size, width=col_width)))