Cancel future if request is dismissed (#104)

francesconazzaro · web-flow · commit 8dab55f915ca · 2024-05-03T09:18:27.000+02:00
diff --git a/cads_broker/dispatcher.py b/cads_broker/dispatcher.py
@@ -178,6 +178,8 @@ def sync_database(self, session: sa.orm.Session) -> None:
                 self.qos.notify_end_of_request(
                     request, session, scheduler=self.internal_scheduler
                 )
+                if future := self.futures.get(request.request_uid):
+                    future.cancel()
                 continue
             # if request is in futures, go on
             if request.request_uid in self.futures:

Original file line number	Diff line number	Diff line change
`@@ -178,6 +178,8 @@ def sync_database(self, session: sa.orm.Session) -> None:`
`178`	`178`	`self.qos.notify_end_of_request(`
`179`	`179`	`request, session, scheduler=self.internal_scheduler`
`180`	`180`	`)`
	`181`	`+ if future := self.futures.get(request.request_uid):`
	`182`	`+ future.cancel()`
`181`	`183`	`continue`
`182`	`184`	`# if request is in futures, go on`
`183`	`185`	`if request.request_uid in self.futures:`