Skip to content

fix(mothership): run same-workflow workflow tools in order instead of failing as busy #8709

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
waleedlatif1 merged 6 commits into from
Oct 7, 2026
Merged

fix(mothership): run same-workflow workflow tools in order instead of failing as busy #8709

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
7fc96da
fix(mothership): run same-workflow workflow tools in order instead of…
waleedlatif1 Oct 7, 2026
c037c03
fix(mothership): keep a workflow for a run whose stream dropped until…
waleedlatif1 Oct 7, 2026
fd8ffd0
fix(mothership): release a dropped run's hold once it settles, even a…
waleedlatif1 Oct 7, 2026
607b58c
fix(mothership): re-send an undelivered workflow tool completion whil…
waleedlatif1 Oct 7, 2026
9e1037d
improvement(mothership): keep each workflow's run-tool slot in one re…
waleedlatif1 Oct 7, 2026
e65f6c7
fix(mothership): clear a dropped run's saved pointer when its hold is…
waleedlatif1 Oct 7, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions apps/sim/hooks/use-execution-stream.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -285,6 +285,11 @@ function reconnectStreamKey(workflowId: string, executionId: string): string {
return `${workflowId}:reconnect:${executionId}`
}

/** Whether a reconnect stream for this execution is currently open in this tab. */
export function isReconnectStreamOpen(workflowId: string, executionId: string): boolean {
return sharedAbortControllers.has(reconnectStreamKey(workflowId, executionId))
}

function abortStream(key: string): void {
const controller = sharedAbortControllers.get(key)
if (!controller) return
Expand Down
Loading
Loading