From 3a1a50fc4caccdb1f5db718ae8f2cbc380360b0e Mon Sep 17 00:00:00 2001 From: Waleed Latif Date: Wed, 4 Nov 2026 01:30:44 -0800 Subject: [PATCH] fix(resume): carry the admitted resume run's ID on outer resume failure logs --- apps/sim/lib/workflows/executor/resume-execution.ts | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/apps/sim/lib/workflows/executor/resume-execution.ts b/apps/sim/lib/workflows/executor/resume-execution.ts index 4a4d6e6311b..9de3b68235f 100644 --- a/apps/sim/lib/workflows/executor/resume-execution.ts +++ b/apps/sim/lib/workflows/executor/resume-execution.ts @@ -243,6 +243,7 @@ export async function executeResumeWorkflow({ actorUserId: preprocessResult.actorUserId, }) + let admittedResumeExecutionId: string | undefined try { const enqueueResult = await PauseResumeManager.enqueueOrStartResume({ executionId, @@ -252,6 +253,7 @@ export async function executeResumeWorkflow({ userId, allowedPauseKinds: ['human'], }) + admittedResumeExecutionId = enqueueResult.resumeExecutionId if (enqueueResult.status === 'queued') { return { @@ -441,7 +443,11 @@ export async function executeResumeWorkflow({ logFailureOnce(logger, 'Resume request failed', error, { executionId, metadata: () => - projectResolvedSecretDiagnosticError(error, undefined, { workflowId, contextId }), + projectResolvedSecretDiagnosticError(error, undefined, { + workflowId, + contextId, + resumeExecutionId: admittedResumeExecutionId, + }), }) if (statusCode !== undefined) { throw new ResumeWorkflowExecutionError(statusCode, toError(error).message, statusCode < 500)