We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1fd2f80 commit eb63281Copy full SHA for eb63281
bqskit/runtime/worker.py
@@ -463,7 +463,13 @@ def _try_step_next_ready_task(self) -> None:
463
except StopIteration as e:
464
self._process_task_completion(task, e.value)
465
466
- except Exception:
+ except Exception as e:
467
+ if type(e) is RuntimeError:
468
+ # In rare cases, a cancelled task will cause a RuntimeError in step or _process_await
469
+ for addr in self._cancelled_task_ids:
470
+ if task.is_descendant_of(addr):
471
+ return
472
+
473
assert self._active_task is not None # for type checker
474
475
# Bubble up errors
0 commit comments