Mastra•4w ago

Parallel Steps `writer.custom` throwing writer is locked

Works for sequencial steps, but getting error for parallel

5 Replies

📝 Created GitHub issue: https://github.com/mastra-ai/mastra/issues/10152 🔍 If you're experiencing an error, please provide a minimal reproducible example to help us resolve it quickly. 🙏 Thank you @arpitBhalla for helping us improve Mastra!

GitHub

Parallel Steps writer.custom throwing writer is locked · Issue #...

This issue was created from Discord post 1439609729952514170: Works for sequencial steps, but getting error for parallel

Stack Overflow

How to create a Minimal, Reproducible Example - Help Center

Stack Overflow | The World’s Largest Online Community for Developers

Grayson•4w ago

Could you please post more information and a minimal reproduction? Thanks!

arpitBhallaOP•4w ago

Something like this

createWorkflow({
    id: 'log-workflow',
    inputSchema: z.any(),
    outputSchema: z.any(),
})
    .parallel([
        createStep({
            id: 'log-step-1',
            description: '',
            inputSchema: z.any(),
            outputSchema: z.any(),
            execute: ({writer}) => writer.custom({type: 'data-log', data: {}}),
        }),
        createStep({
            id: 'log-step-2',
            description: '',
            inputSchema: z.any(),
            outputSchema: z.any(),
            execute: ({writer}) => writer.custom({type: 'data-log', data: {}}),
        }),
    ])
    .commit();

createWorkflow({
    id: 'log-workflow',
    inputSchema: z.any(),
    outputSchema: z.any(),
})
    .parallel([
        createStep({
            id: 'log-step-1',
            description: '',
            inputSchema: z.any(),
            outputSchema: z.any(),
            execute: ({writer}) => writer.custom({type: 'data-log', data: {}}),
        }),
        createStep({
            id: 'log-step-2',
            description: '',
            inputSchema: z.any(),
            outputSchema: z.any(),
            execute: ({writer}) => writer.custom({type: 'data-log', data: {}}),
        }),
    ])
    .commit();

Ward•4w ago

It's on the list to get these things solved this week

Abhi Aiyer•3w ago

I have a fix for this here https://github.com/mastra-ai/mastra/pull/10463/files

GitHub

Parallel stream fix by abhiaiyer91 · Pull Request #10463 · mastra...

Fixes #10152 Summary by CodeRabbit Improvements Custom writer method now returns a Promise, ensuring writes are performed sequentially with proper serialization. Tests Added comprehensive t...

Gaming

Programming

Parallel Steps `writer.custom` throwing writer is locked

Did you find this page helpful?