Skip to content

Commit 2ae1aa6

Browse files
fix cancelled status
1 parent f095671 commit 2ae1aa6

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

cads_broker/dispatcher.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@
3232
"processing": "running",
3333
"error": "failed",
3434
"finished": "successful",
35-
"cancelled": "failed",
3635
}
3736

3837
WORKERS_MULTIPLIER = float(os.getenv("WORKERS_MULTIPLIER", 1))
@@ -365,7 +364,7 @@ def on_future_done(self, future: distributed.Future) -> None:
365364
logger.info("worker killed: re-queueing", job_id=future.key)
366365
db.requeue_request(request_uid=future.key, session=session)
367366
self.queue.add(future.key, request)
368-
else:
367+
elif future.status != "cancelled":
369368
request = db.set_request_status(
370369
future.key,
371370
job_status,

0 commit comments

Comments
 (0)