Skip to content

Commit 570a962

Browse files
fix broker
1 parent f276f54 commit 570a962

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

cads_broker/dispatcher.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -255,10 +255,9 @@ def sync_database(self, session: sa.orm.Session) -> None:
255255
self.queue.reset()
256256
self.qos.reload_rules(session)
257257
db.reset_qos_rules(session, self.qos)
258+
session.commit()
258259

259-
statement = sa.select(db.SystemRequest).where(
260-
db.SystemRequest.status.in_(("running", "dismissed"))
261-
)
260+
statement = sa.select(db.SystemRequest).where(db.SystemRequest.status == "running")
262261
dask_tasks = get_tasks(self.client)
263262
for request in session.scalars(statement):
264263
# if request is in futures, go on

0 commit comments

Comments
 (0)