Skip to content

Commit 426222c

Browse files
Fix decrementing running and queued counters in QoS rules
1 parent 637fe0d commit 426222c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

cads_broker/database.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -475,7 +475,7 @@ def decrement_qos_rule_running(rules: list, session: sa.orm.Session):
475475
"""Increment the running counter of a QoS rule."""
476476
for rule in rules:
477477
qos_rule = get_qos_rule(str(rule.__hash__()), session)
478-
qos_rule.running -= 1
478+
qos_rule.running = max(0, qos_rule.running - 1)
479479
session.commit()
480480

481481

@@ -489,7 +489,7 @@ def delete_request_qos_status(request_uid: str, rules: list, session: sa.orm.Ses
489489
qos_rule = add_qos_rule(rule=rule, session=session)
490490
if qos_rule in request.qos_rules:
491491
request.qos_rules.remove(qos_rule)
492-
qos_rule.queued -= 1
492+
qos_rule.queued = max(0, qos_rule.queued - 1)
493493
qos_rule.running += 1
494494
session.commit()
495495

0 commit comments

Comments
 (0)