Mastra•2mo ago

resuming workflow as step not possible

Hello! I have a simple workflow that includes a step that is a workflow. It seems that it is not possible to suspend from within a step of this sub-workflow and then resume. In fact, attempting to do so causes the mastra server to crash (requiring a restart) with the attached error.

Here is my simple full workflow:

const loopStep = createWorkflow({
  id: "loopStep",
  inputSchema: loopInputSchema,
  outputSchema: loopInputSchema,
})
  .then(evaluateStep)
  .then(advocateStep)
  .commit();

export const supportWorkflow = createWorkflow({
  id: "supportWorkflow",
  inputSchema: intakeInputSchema,
  outputSchema: z.object({}),
})
  .then(intakeStep)
  .dountil(
    loopStep,
    async ({ inputData: { problemId, iterationCount } }) =>
      !problemId || iterationCount > 10
  )
  .commit();

const loopStep = createWorkflow({
  id: "loopStep",
  inputSchema: loopInputSchema,
  outputSchema: loopInputSchema,
})
  .then(evaluateStep)
  .then(advocateStep)
  .commit();

export const supportWorkflow = createWorkflow({
  id: "supportWorkflow",
  inputSchema: intakeInputSchema,
  outputSchema: z.object({}),
})
  .then(intakeStep)
  .dountil(
    loopStep,
    async ({ inputData: { problemId, iterationCount } }) =>
      !problemId || iterationCount > 10
  )
  .commit();

const loopStep = createWorkflow({
  id: "loopStep",
  inputSchema: loopInputSchema,
  outputSchema: loopInputSchema,
})
  .then(evaluateStep)
  .then(advocateStep)
  .commit();

export const supportWorkflow = createWorkflow({
  id: "supportWorkflow",
  inputSchema: intakeInputSchema,
  outputSchema: z.object({}),
})
  .then(intakeStep)
  .dountil(
    loopStep,
    async ({ inputData: { problemId, iterationCount } }) =>
      !problemId || iterationCount > 10
  )
  .commit();

const loopStep = createWorkflow({
  id: "loopStep",
  inputSchema: loopInputSchema,
  outputSchema: loopInputSchema,
})
  .then(evaluateStep)
  .then(advocateStep)
  .commit();

export const supportWorkflow = createWorkflow({
  id: "supportWorkflow",
  inputSchema: intakeInputSchema,
  outputSchema: z.object({}),
})
  .then(intakeStep)
  .dountil(
    loopStep,
    async ({ inputData: { problemId, iterationCount } }) =>
      !problemId || iterationCount > 10
  )
  .commit();

Using the JS client TWO suspend events are streamed:

{
    "type": "step-suspended",
    "payload": {
        "id": "loopStep.evaluateStep",
        "stepCallId": "00e7634e-58d1-44a1-be31-b1028e629b9c",
        "status": "suspended",
        "suspendPayload": {
            "responseToUser": "",
            "responseToRepresentative": "xxx",
            "awaiting": "representative"
        },
        "suspendedAt": 1761234434191
    }
}

{
    "type": "step-suspended",
    "payload": {
        "id": "loopStep.evaluateStep",
        "stepCallId": "00e7634e-58d1-44a1-be31-b1028e629b9c",
        "status": "suspended",
        "suspendPayload": {
            "responseToUser": "",
            "responseToRepresentative": "xxx",
            "awaiting": "representative"
        },
        "suspendedAt": 1761234434191
    }
}

{
    "type": "step-suspended",
    "payload": {
        "id": "loopStep.evaluateStep",
        "stepCallId": "00e7634e-58d1-44a1-be31-b1028e629b9c",
        "status": "suspended",
        "suspendPayload": {
            "responseToUser": "",
            "responseToRepresentative": "xxx",
            "awaiting": "representative"
        },
        "suspendedAt": 1761234434191
    }
}

{
    "type": "step-suspended",
    "payload": {
        "id": "loopStep.evaluateStep",
        "stepCallId": "00e7634e-58d1-44a1-be31-b1028e629b9c",
        "status": "suspended",
        "suspendPayload": {
            "responseToUser": "",
            "responseToRepresentative": "xxx",
            "awaiting": "representative"
        },
        "suspendedAt": 1761234434191
    }
}

As well as:

{
    "type": "step-suspended",
    "payload": {
        "id": "loopStep",
        "stepCallId": "01aaad99-df3d-4dc2-bd0b-2074de3145ba",
        "status": "suspended",
        "suspendPayload": {
            "responseToUser": "",
            "responseToRepresentative": "xxx",
            "awaiting": "representative",
            "__workflow_meta": {
                "runId": "207c1619-ff79-429b-a1ad-0eccb198d4d6",
                "path": [
                    "evaluateStep"
                ]
            }
        },
        "suspendedAt": 1761234434335
    }
}

{
    "type": "step-suspended",
    "payload": {
        "id": "loopStep",
        "stepCallId": "01aaad99-df3d-4dc2-bd0b-2074de3145ba",
        "status": "suspended",
        "suspendPayload": {
            "responseToUser": "",
            "responseToRepresentative": "xxx",
            "awaiting": "representative",
            "__workflow_meta": {
                "runId": "207c1619-ff79-429b-a1ad-0eccb198d4d6",
                "path": [
                    "evaluateStep"
                ]
            }
        },
        "suspendedAt": 1761234434335
    }
}

{
    "type": "step-suspended",
    "payload": {
        "id": "loopStep",
        "stepCallId": "01aaad99-df3d-4dc2-bd0b-2074de3145ba",
        "status": "suspended",
        "suspendPayload": {
            "responseToUser": "",
            "responseToRepresentative": "xxx",
            "awaiting": "representative",
            "__workflow_meta": {
                "runId": "207c1619-ff79-429b-a1ad-0eccb198d4d6",
                "path": [
                    "evaluateStep"
                ]
            }
        },
        "suspendedAt": 1761234434335
    }
}

{
    "type": "step-suspended",
    "payload": {
        "id": "loopStep",
        "stepCallId": "01aaad99-df3d-4dc2-bd0b-2074de3145ba",
        "status": "suspended",
        "suspendPayload": {
            "responseToUser": "",
            "responseToRepresentative": "xxx",
            "awaiting": "representative",
            "__workflow_meta": {
                "runId": "207c1619-ff79-429b-a1ad-0eccb198d4d6",
                "path": [
                    "evaluateStep"
                ]
            }
        },
        "suspendedAt": 1761234434335
    }
}

I have triped resuming using BOTH id's. Neither works.

message.txt7.24KB

flippyheadOP•10/23/25, 4:30 PM

But now I have doubts.

flippyheadOP•10/23/25, 4:30 PM

The language in your docs here: https://mastra.ai/en/docs/streaming/workflow-streaming#resuming-an-interrupted-workflow-stream says "If a workflow stream is closed or interrupted for any reason, you can resume it with the resumeStreamVNext method."

Workflow Streaming | Streaming | Mastra

Learn how to use workflow streaming in Mastra, including handling workflow execution events, step streaming, and workflow integration with agents and tools.

flippyheadOP•10/23/25, 4:31 PM

But the language here https://mastra.ai/en/reference/streaming/workflows/resumeStreamVNext says: "The .resumeStreamVNext() method resumes a suspended workflow run with new data, allowing you to continue execution from a specific step and to observe the stream of events."

Reference: Run.resumeStreamVNext() | Workflows | Mastra Docs

Documentation for the Run.resumeStreamVNext()Run.resumeStreamVNext() method in workflows, which enables real-time resumption and streaming of suspended workflow runs.

flippyheadOP•10/23/25, 4:31 PM

Which makes it seem like this method either is used specifically for suspending workflows or used for disconnecting from runs

flippyheadOP•10/23/25, 4:31 PM

Either way, neither works!

flippyheadOP•10/23/25, 6:21 PM

And now I see, in part, why this is so confusing. You expose

resumeStreamVNext

resumeStreamVNext

on the client SDK but you do NOT expose streamVNextstreamVNext

flippyheadOP•10/23/25, 6:22 PM

I have no idea why it works this way but it means that, confusingly, you have to deal with a mix of stream formats. And, from what I can tell, it's not possible to stream Vnext when using the JS client at all

_roamin_•10/23/25, 9:05 PM

yeah, something is definitely going on... checking now

_roamin_•10/23/25, 9:13 PM

I do see streamVNextstreamVNext and

resumeStreamVNext

resumeStreamVNext

on my end, are you sure you're using a recent client sdk?

flippyheadOP•10/23/25, 10:38 PM

@Romain "@mastra/client-js": "^0.16.1",

flippyheadOP•10/23/25, 10:39 PM

Which has exactly this:

 /**
     * Creates a new workflow run
     * @param params - Optional object containing the optional runId
     * @returns Promise containing the runId of the created run with methods to control execution
     */
    createRunAsync(params?: {
        runId?: string;
    }): Promise<{
        runId: string;
        start: (params: {
            inputData: Record<string, any>;
            runtimeContext?: RuntimeContext | Record<string, any>;
            tracingOptions?: TracingOptions;
        }) => Promise<{
            message: string;
        }>;
        watch: (onRecord: (record: WorkflowWatchResult) => void) => Promise<void>;
        resume: (params: {
            step: string | string[];
            resumeData?: Record<string, any>;
            runtimeContext?: RuntimeContext | Record<string, any>;
            tracingOptions?: TracingOptions;
        }) => Promise<{
            message: string;
        }>;
        stream: (params: {
            inputData: Record<string, any>;
            runtimeContext?: RuntimeContext | Record<string, any>;
        }) => Promise<ReadableStream>;
        startAsync: (params: {
            inputData: Record<string, any>;
            runtimeContext?: RuntimeContext | Record<string, any>;
            tracingOptions?: TracingOptions;
        }) => Promise<WorkflowRunResult>;
        resumeAsync: (params: {
            step: string | string[];
            resumeData?: Record<string, any>;
            runtimeContext?: RuntimeContext | Record<string, any>;
            tracingOptions?: TracingOptions;
        }) => Promise<WorkflowRunResult>;
        resumeStreamVNext: (params: {
            step: string | string[];
            resumeData?: Record<string, any>;
            runtimeContext?: RuntimeContext | Record<string, any>;
        }) => Promise<ReadableStream>;
    }>;

 /**
     * Creates a new workflow run
     * @param params - Optional object containing the optional runId
     * @returns Promise containing the runId of the created run with methods to control execution
     */
    createRunAsync(params?: {
        runId?: string;
    }): Promise<{
        runId: string;
        start: (params: {
            inputData: Record<string, any>;
            runtimeContext?: RuntimeContext | Record<string, any>;
            tracingOptions?: TracingOptions;
        }) => Promise<{
            message: string;
        }>;
        watch: (onRecord: (record: WorkflowWatchResult) => void) => Promise<void>;
        resume: (params: {
            step: string | string[];
            resumeData?: Record<string, any>;
            runtimeContext?: RuntimeContext | Record<string, any>;
            tracingOptions?: TracingOptions;
        }) => Promise<{
            message: string;
        }>;
        stream: (params: {
            inputData: Record<string, any>;
            runtimeContext?: RuntimeContext | Record<string, any>;
        }) => Promise<ReadableStream>;
        startAsync: (params: {
            inputData: Record<string, any>;
            runtimeContext?: RuntimeContext | Record<string, any>;
            tracingOptions?: TracingOptions;
        }) => Promise<WorkflowRunResult>;
        resumeAsync: (params: {
            step: string | string[];
            resumeData?: Record<string, any>;
            runtimeContext?: RuntimeContext | Record<string, any>;
            tracingOptions?: TracingOptions;
        }) => Promise<WorkflowRunResult>;
        resumeStreamVNext: (params: {
            step: string | string[];
            resumeData?: Record<string, any>;
            runtimeContext?: RuntimeContext | Record<string, any>;
        }) => Promise<ReadableStream>;
    }>;

Mastra Triager•10/24/25, 12:05 PM

Created GitHub issue: https://github.com/mastra-ai/mastra/issues/9228

GitHub

[DISCORD:1430946646291644528] resuming workflow as step not possibl...

This issue was created from Discord post: https://discord.com/channels/1309558646228779139/1430946646291644528 Hello! I have a simple workflow that includes a step that is a workflow. It seems that...

_roamin_•10/24/25, 5:34 PM

Oh, I see, that's the result of createRunAsynccreateRunAsync, I was looking at the direct workflowworkflow api, my bad

_roamin_•10/24/25, 5:35 PM

Definitely an oversight, but we are streamlining the workflow APIs, so the vnextvnext stuff should become obsolete, let me check if the migration has already been done

_roamin_•10/24/25, 5:45 PM

yeah, so streamstream is now equivalent to streamVNextstreamVNext so you should be good on that side

_roamin_•10/24/25, 5:46 PM

how do you resume the workflow? Could you share a repro example I could use to debug? Thanks!

wiz2202•10/24/25, 8:57 PM

@Romain Hey- I am running into this same issue, so I can provide a simpified test example as well

wiz2202•10/24/25, 9:08 PM

wiz2202•10/24/25, 9:09 PM

export async function PATCH(
req: NextRequest,
{ params }: { params: Promise<{ runId: string }> }
) {
try {
const { runId } = await params;
const body = await req.json();

console.log("Resume request body:", JSON.stringify(body, null, 2));

// Expect { stepPath: string[], resumeData: any }
let stepPath = body.stepPath;
const resumeData = body.resumeData (Array.isArray(stepPath) && stepPath.length === 0)) {
return new Response(
JSON.stringify({
error: "stepPath is required and cannot be empty",
received: stepPath
}),
{
status: 400,
headers: { "Content-Type": "application/json" }
}
);
}

const workflow = mastra.getWorkflow("exampleParallelSuspendWorkflow");
const run = await workflow.createRunAsync({ runId });

console.log("Calling resumeStreamVNext with step:", stepPath);

return streamWorkflowRun(() => {
return run.resumeStreamVNext({
step: stepPath,
resumeData,
});
});
} catch (error) {
console.error("Error resuming workflow:", error);
return new Response(JSON.stringify({ error: String(error) }), {
status: 500,
headers: { "Content-Type": "application/json" },
});
}
}

wiz2202•10/24/25, 9:13 PM

@Romain when I pass step path as subworkflow1, it says its running but the subworkflow does not keep running.

When I pass the stepPath as "subworkflow1.Step2Suspend" then it cant find that as a supended step

wiz2202•10/24/25, 9:14 PM

and that one returns this error:

Calling resumeStreamVNext with step: [ 'subworkflow1.Step2Suspend' ]
[Error: This workflow step "subworkflow1.Step2Suspend" was not suspended. Available suspended steps: [subworkflow1, subworkflow2, subworkflow3]]
⨯ unhandledRejection: [Error: This workflow step "subworkflow1.Step2Suspend" was not suspended. Available suspended steps: [subworkflow1, subworkflow2, subworkflow3]]
⨯ unhandledRejection: [Error: This workflow step "subworkflow1.Step2Suspend" was not suspended. Available suspended steps: [subworkflow1, subworkflow2, subworkflow3]]

wiz2202•10/24/25, 9:14 PM

which I believe is the same error @flippyhead is facing

wiz2202•10/24/25, 9:15 PM

The part I am confused abt though is it works in the local mastra dev server so I think it might just be a bug with how I am resuming

_roamin_•10/24/25, 9:40 PM

I think that's because you're not passing the step to resume correctly. It should be an array of strings that describe the path to the suspended step.
You should try this instead [ 'subworkflow1', 'Step2Suspend' ][ 'subworkflow1', 'Step2Suspend' ]

Wwiz2202 The part I am confused abt though is it works in the local mastra dev server so ...

wiz2202•10/25/25, 11:23 PM

@roamin I am still running into my original issue but going to make a seperate help-bug about it because I think it is a real bug

Wwiz2202 @_roamin_ I am still running into my original issue but going to make a seperate...

_roamin_•10/27/25, 4:25 PM

Thanks for opening that other issue

Taofeeq•10/29/25, 4:45 PM

Hi @flippyhead @wiz2202 , this PR - https://github.com/mastra-ai/mastra/pull/9459 fixes the issue
Once it's published, you'll be able to resume the step using the chained id - loopStep.evaluateSteploopStep.evaluateStep or just the nested workflow step id loopSteploopStep

GitHub

resume nested workflow step with chained id by taofeeq-deru · Pull...

Description

Allow resuming nested workflow step with chained id
Example, you have a workflow like this
export const supportWorkflow = mainWorkflow.then(nestedWorkflow).commit();

And a step in nes...

resuming workflow as step not possible

Similar Threads

Similar Threads

Similar Threads