diff --git a/utils/monitor_work_queue.py b/utils/monitor_work_queue.py index 0c5ba2deb..2b80aed05 100755 --- a/utils/monitor_work_queue.py +++ b/utils/monitor_work_queue.py @@ -31,7 +31,7 @@ def main(): except Exception, e: failed = e - if work_queue_size > 100 and work_queue_size >= (redis_work_queue - QUEUE_DROP_AMOUNT): + if work_queue_size > 100 and work_queue_size > (redis_work_queue + QUEUE_DROP_AMOUNT): failed = True if failed: