Limiting work queue checks.

This commit is contained in:
Samuel Clay 2021-01-20 17:20:01 -05:00
parent e4cfb73b4f
commit 3811d288d8

View file

@ -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: