Skip to content

Commit 0aa0fd2

Browse files
fix too many running requests
1 parent 2ca514c commit 0aa0fd2

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

cads_broker/dispatcher.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -330,6 +330,11 @@ def sync_database(self, session: sa.orm.Session) -> None:
330330
# if the task is in memory and it is not in the futures
331331
# it means that the task has been lost by the broker (broker has been restarted)
332332
# the task is successful.
333+
request = db.set_request_status(
334+
request_uid=request.request_uid,
335+
status="successful",
336+
session=session,
337+
)
333338
self.qos.notify_end_of_request(
334339
request, session, scheduler=self.internal_scheduler
335340
)

0 commit comments

Comments
 (0)