We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ead6b3b commit 490e98fCopy full SHA for 490e98f
cads_broker/dispatcher.py
@@ -759,7 +759,9 @@ def run(self) -> None:
759
with self.session_maker_read() as session_read:
760
if (rules_hash := get_rules_hash(self.qos.path)) != self.qos.rules_hash:
761
logger.info("reloading qos rules")
762
- self.qos.reload_rules(session=session_read)
+ with self.session_maker_write() as session_write:
763
+ self.qos.reload_rules(session=session_write)
764
+ db.reset_qos_rules(session_write, self.qos)
765
self.qos.rules_hash = rules_hash
766
self.qos.environment.set_session(session_read)
767
# expire_on_commit=False is used to detach the accepted requests without an error
0 commit comments