M

Mastra•3mo ago•

4 replies

wiz2202

inputData is undefined on resume when step is preceded by .map()

Mastra Version: @mastra/core@1.0.0-beta.14

Description:
When resuming a suspended workflow step that is preceded by a .map() step, inputData is undefined instead of containing the data from the .map() output. The .map() step doesn't re-execute on resume, and the original inputData is not restored from the snapshot.

Expected Behavior:
Based on the suspend/resume docs, inputData should be accessible on both first run and resume:

execute: async ({ inputData, resumeData, suspend }) => {
const { userEmail } = inputData; // <-- docs show this works on resume
const { approved } = resumeData ?? {};
// ...
}
Actual Behavior:
On resume, inputData is undefined when the step is preceded by a .map().

Debug Output

First run (works correctly):

[INPUT DATA] [ 'treatments', 'sources', 'condition', 'therapy' ]
[SUSPEND DATA] []
[RESUME DATA] []

On resume (inputData is empty):

[INPUT DATA] [] Should have: treatments, sources, condition, therapy
[SUSPEND DATA] [ 'treatments', 'condition', 'therapy', 'sources' ]
[RESUME DATA] [ 'selectedTreatmentNames' ]
Workflow Structure

export const myWorkflow = createWorkflow({...})
.then(searchStep)
.map(async ({ getStepResult }) => {
const result = getStepResult(searchStep)!;
return {
treatments: result.treatments,
sources: result.sources,
condition: result.condition,
};
})
.then(suspendableStep) // <-- inputData is undefined on resume
.commit();