Skip to content

Commit ed25dda

Browse files
Fix NoResultFound error sometimes happening in the broker for old requests
1 parent 5c3ce08 commit ed25dda

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

cads_broker/dispatcher.py

+9-1
Original file line numberDiff line numberDiff line change
@@ -566,7 +566,15 @@ def sync_futures(self) -> None:
566566

567567
def on_future_done(self, future: distributed.Future) -> str:
568568
with self.session_maker_write() as session:
569-
request = db.get_request(future.key, session=session)
569+
try:
570+
request = db.get_request(future.key, session=session)
571+
except db.NoResultFound:
572+
logger.warning(
573+
"request not found",
574+
job_id=future.key,
575+
dask_status=future.status,
576+
)
577+
return future.key
570578
if request.status != "running":
571579
return
572580
if future.status == "finished":

0 commit comments

Comments
 (0)