Skip to content

Commit 6ac140c

Browse files
jpsamarooJamesWrigley
authored andcommitted
cancellation: Wrap InterruptException in DTaskFailedException
1 parent 3aba122 commit 6ac140c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/cancellation.jl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ function _cancel!(state, tid, force, halt_sch)
9696
for task in state.ready
9797
tid !== nothing && task.id != tid && continue
9898
@dagdebug tid :cancel "Cancelling ready task"
99-
state.cache[task] = InterruptException()
99+
state.cache[task] = DTaskFailedException(task, task, InterruptException())
100100
state.errored[task] = true
101101
Sch.set_failed!(state, task)
102102
end
@@ -106,7 +106,7 @@ function _cancel!(state, tid, force, halt_sch)
106106
for task in keys(state.waiting)
107107
tid !== nothing && task.id != tid && continue
108108
@dagdebug tid :cancel "Cancelling waiting task"
109-
state.cache[task] = InterruptException()
109+
state.cache[task] = DTaskFailedException(task, task, InterruptException())
110110
state.errored[task] = true
111111
Sch.set_failed!(state, task)
112112
end

0 commit comments

Comments
 (0)