Streaming from a workflow step when using Inngest

WorkflowsAgent

I'm currently struggling with streaming an agent response from a workflow when running it through the Inngest Dev Server.

For the Mastra workflow I'm using the

workflowRoute

workflowRoute

with patched streaming support as described in Help: Cannot stream anything from workflows after recent update.
This works fine when using Mastra standalone and consuming it with AI-SDK on the frontend.

But when I run it through Inngest, I get an error inside

@mastra/inngest

@mastra/inngest

The "transform.writable" property must be an instance of WritableStream. Received undefined

The "transform.writable" property must be an instance of WritableStream. Received undefined

I found an option on the

inngestServe

inngestServe

function that I tried:

  {
        path: "/api/inngest",
        method: "ALL",
        createHandler: async ({ mastra }) => inngestServe({ mastra, inngest, registerOptions: {
          streaming: "force"
        }}),
      },

  {
        path: "/api/inngest",
        method: "ALL",
        createHandler: async ({ mastra }) => inngestServe({ mastra, inngest, registerOptions: {
          streaming: "force"
        }}),
      },

Unfortunately this didn't resolve the issue.

I know this scenario could be considered hacky because of the patch I linked above. But I was just curious if there are any working examples for this use case and whether or not this will be supported at some point.

Thanks in advance for any help!

Mastra•4mo ago•

5 replies

Sebastian

Streaming from a workflow step when using Inngest

WorkflowsAgent

I'm currently struggling with streaming an agent response from a workflow when running it through the Inngest Dev Server.

For the Mastra workflow I'm using the

workflowRoute

workflowRoute

@mastra/inngest

@mastra/inngest

The "transform.writable" property must be an instance of WritableStream. Received undefined

The "transform.writable" property must be an instance of WritableStream. Received undefined

I found an option on the

inngestServe

inngestServe

function that I tried:

  {
        path: "/api/inngest",
        method: "ALL",
        createHandler: async ({ mastra }) => inngestServe({ mastra, inngest, registerOptions: {
          streaming: "force"
        }}),
      },

  {
        path: "/api/inngest",
        method: "ALL",
        createHandler: async ({ mastra }) => inngestServe({ mastra, inngest, registerOptions: {
          streaming: "force"
        }}),
      },

Streaming from a workflow step when using Inngest

Similar Threads

Streaming from a workflow step when using Inngest

Similar Threads

Similar Threads

Similar Threads