@@ -336,23 +336,21 @@ def manage_dismissed_request(self, request, session):
336
336
session = session ,
337
337
)
338
338
previous_status = dismission_metadata .get ("previous_status" , "accepted" )
339
+ if dismission_metadata .get ("reason" , "DismissedRequest" ) == "PermissionError" :
340
+ request .status = "failed"
341
+ request .finished_at = datetime .datetime .now ()
342
+ else :
343
+ request .status = "deleted"
339
344
if previous_status == "running" :
340
345
self .qos .notify_end_of_request (
341
346
request , session , scheduler = self .internal_scheduler
342
347
)
343
- request .status = "deleted"
344
348
elif previous_status == "accepted" :
345
349
self .queue .pop (request .request_uid , None )
346
350
self .qos .notify_dismission_of_request (
347
351
request , session , scheduler = self .internal_scheduler
348
352
)
349
- if (
350
- reason := dismission_metadata .get ("reason" , "DismissedRequest" )
351
- ) == "DismissedRequest" :
352
- request .status = "deleted"
353
- elif reason == "PermissionError" :
354
- request .status = "failed"
355
- request .finished_at = datetime .datetime .now ()
353
+ logger .info ("job has finished" , ** db .logger_kwargs (request = request ))
356
354
return session
357
355
358
356
@cachetools .cachedmethod (lambda self : self .ttl_cache )
0 commit comments