Skip to content

Fix: Propagate terminal worker failures and stop queued DAG work - #6140

Open
mday-io wants to merge 1 commit into
SQLMesh:mainfrom
mday-io:fix/concurrency-terminal-errors
Open

mday-io wants to merge 1 commit into
SQLMesh:mainfrom
mday-io:fix/concurrency-terminal-errors

Conversation

@mday-io

@mday-io mday-io commented Oct 13, 2026 •

Copy link
Copy Markdown
Collaborator

Summary

Worker cancellation could leave callers waiting indefinitely. Propagate the original exception and stop queued work after a terminal failure.

- unfinished future or queued work after failure
+ propagate failure, stop queued work, drain active workers

Test Plan

  • Reproduced the original hangs and queued-work failure.
  • Tested both error modes, worker draining, exception identity and executor reuse.
  • Ran make style and all make fast-test batches: 2,862 passed.
  • Confirm current-head CI, including Windows.

@mday-io
mday-io marked this pull request as ready for review October 14, 2026 19:27
Signed-off-by: mday-io <mdaytn@gmail.com>
@mday-io
mday-io force-pushed the fix/concurrency-terminal-errors branch from edfb13b to 8be00c3 Compare October 14, 2026 19:34
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant