Skip to content

Commit 72c721a

Browse files
committed
feat(job): resolve job.wait() Future on job cancel
1 parent d01e022 commit 72c721a

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

dcp/api/job.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -151,6 +151,7 @@ def handle_complete(resultHandle):
151151
results.append(result)
152152
complete_future.set_result(results)
153153
self.js_ref.on("complete", handle_complete)
154+
self.js_ref.on("cancel", handle_complete)
154155
return complete_future
155156

156157
def exec(self, *args):

0 commit comments

Comments
 (0)