Revert #1766 (Use stream control frame for transparent reconnection)

[VaguelySerious]

No description provided.

[changeset-bot]

🦋 Changeset detected

Latest commit: 130bff9

The changes in this PR will be included in the next version bump.

This PR includes changesets to release 18 packages

Name	Type
@workflow/world-vercel	Patch
@workflow/cli	Patch
@workflow/core	Patch
@workflow/web	Patch
workflow	Patch
@workflow/world-testing	Patch
@workflow/builders	Patch
@workflow/next	Patch
@workflow/nitro	Patch
@workflow/vitest	Patch
@workflow/web-shared	Patch
@workflow/ai	Patch
@workflow/astro	Patch
@workflow/nest	Patch
@workflow/rollup	Patch
@workflow/sveltekit	Patch
@workflow/vite	Patch
@workflow/nuxt	Patch

Not sure what this means? Click here to learn what changesets are.

Click here if you're a maintainer who wants to add another changeset to this PR

[vercel]

The latest updates on your projects. Learn more about Vercel for GitHub.

Project	Deployment	Actions	Updated (UTC)
example-nextjs-workflow-turbopack	Ready	Preview, Comment	Apr 17, 2026 0:07am
example-nextjs-workflow-webpack	Ready	Preview, Comment	Apr 17, 2026 0:07am
example-workflow	Ready	Preview, Comment	Apr 17, 2026 0:07am
workbench-astro-workflow	Ready	Preview, Comment	Apr 17, 2026 0:07am
workbench-express-workflow	Ready	Preview, Comment	Apr 17, 2026 0:07am
workbench-fastify-workflow	Ready	Preview, Comment	Apr 17, 2026 0:07am
workbench-hono-workflow	Ready	Preview, Comment	Apr 17, 2026 0:07am
workbench-nitro-workflow	Ready	Preview, Comment	Apr 17, 2026 0:07am
workbench-nuxt-workflow	Ready	Preview, Comment	Apr 17, 2026 0:07am
workbench-sveltekit-workflow	Ready	Preview, Comment	Apr 17, 2026 0:07am
workbench-vite-workflow	Ready	Preview, Comment	Apr 17, 2026 0:07am
workflow-docs	Ready	Preview, Comment, Open in v0	Apr 17, 2026 0:07am
workflow-swc-playground	Ready	Preview, Comment	Apr 17, 2026 0:07am
workflow-web	Ready	Preview, Comment	Apr 17, 2026 0:07am

[github-actions]

🧪 E2E Test Results

❌ Some tests failed

Summary

	Passed	Failed	Skipped	Total
✅ ▲ Vercel Production	901	0	67	968
✅ 💻 Local Development	970	0	86	1056
✅ 📦 Local Production	970	0	86	1056
✅ 🐘 Local Postgres	970	0	86	1056
✅ 🪟 Windows	88	0	0	88
❌ 🌍 Community Worlds	139	83	0	222
✅ 📋 Other	246	0	18	264
Total	4284	83	343	4710

❌ Failed Tests

🌍 Community Worlds (83 failed)

mongodb (11 failed):

• readableStreamWorkflow | wrun_01KPCC5EA4SY8F85FPKTAGEHQT
• hookWorkflow is not resumable via public webhook endpoint | wrun_01KPCC63TXY3QX7VSNPZKE256S
• webhookWorkflow | wrun_01KPCC6CD1YQM6BMXTQZ2F0589
• outputStreamWorkflow no startIndex (reads all chunks)
• outputStreamWorkflow negative startIndex (reads from end)
• outputStreamWorkflow - getTailIndex and getStreamChunks getTailIndex returns correct index after stream completes
• outputStreamWorkflow - getTailIndex and getStreamChunks getTailIndex returns -1 before any chunks are written
• outputStreamWorkflow - getTailIndex and getStreamChunks getStreamChunks returns same content as reading the stream
• outputStreamInsideStepWorkflow - getWritable() called inside step functions | wrun_01KPCC9CXF8NXBCV1C5HBRBAZX
• concurrent hook token conflict - two workflows cannot use the same hook token simultaneously | wrun_01KPCCDPWYYK7SDDVZAS5RTVZR
• resilient start: addTenWorkflow completes when run_created returns 500 | wrun_01KPCCKFNAX2G2S1C0NYHRNBBY

redis (7 failed):

• hookWorkflow is not resumable via public webhook endpoint | wrun_01KPCC63TXY3QX7VSNPZKE256S
• outputStreamWorkflow negative startIndex (reads from end)
• outputStreamWorkflow - getTailIndex and getStreamChunks getTailIndex returns correct index after stream completes
• outputStreamWorkflow - getTailIndex and getStreamChunks getTailIndex returns -1 before any chunks are written
• outputStreamWorkflow - getTailIndex and getStreamChunks getStreamChunks returns same content as reading the stream
• concurrent hook token conflict - two workflows cannot use the same hook token simultaneously | wrun_01KPCCDPWYYK7SDDVZAS5RTVZR
• resilient start: addTenWorkflow completes when run_created returns 500 | wrun_01KPCCKFNAX2G2S1C0NYHRNBBY

turso (65 failed):

• addTenWorkflow | wrun_01KPCC506KXKF8ZQFS6V3PP3HB
• addTenWorkflow | wrun_01KPCC506KXKF8ZQFS6V3PP3HB
• wellKnownAgentWorkflow (.well-known/agent) | wrun_01KPCC4WN8FCDAQPVHJ7H9T999
• should work with react rendering in step
• promiseAllWorkflow | wrun_01KPCC57EBAXD5SYYG1NXKEQZG
• promiseRaceWorkflow | wrun_01KPCC5ADWARGMJEV2GD25QRE4
• promiseAnyWorkflow | wrun_01KPCC5CD45Y6ZWGNWNXCSCT56
• importedStepOnlyWorkflow | wrun_01KPCC58S4M82M27K5G7BWJQ10
• readableStreamWorkflow | wrun_01KPCC5EA4SY8F85FPKTAGEHQT
• hookWorkflow | wrun_01KPCC5R3BCZVDRPMMPB3PHZMZ
• hookWorkflow is not resumable via public webhook endpoint | wrun_01KPCC63TXY3QX7VSNPZKE256S
• webhookWorkflow | wrun_01KPCC6CD1YQM6BMXTQZ2F0589
• sleepingWorkflow | wrun_01KPCC6HSB8PERDS6F4X9EP807
• parallelSleepWorkflow | wrun_01KPCC6Y1H2E47DTNC2B798MCX
• nullByteWorkflow | wrun_01KPCC725CJC34F4XVJ7YVQY5Z
• workflowAndStepMetadataWorkflow | wrun_01KPCC74CV9C81FSPM861WAZN1
• outputStreamWorkflow no startIndex (reads all chunks)
• outputStreamWorkflow positive startIndex (skips first chunk)
• outputStreamWorkflow negative startIndex (reads from end)
• outputStreamWorkflow - getTailIndex and getStreamChunks getTailIndex returns correct index after stream completes
• outputStreamWorkflow - getTailIndex and getStreamChunks getTailIndex returns -1 before any chunks are written
• outputStreamWorkflow - getTailIndex and getStreamChunks getStreamChunks returns same content as reading the stream
• outputStreamInsideStepWorkflow - getWritable() called inside step functions | wrun_01KPCC9CXF8NXBCV1C5HBRBAZX
• fetchWorkflow | wrun_01KPCC9SQ9Q4BRQVSEHCJAN95T
• promiseRaceStressTestWorkflow | wrun_01KPCC9WR63DNDE3D6C163RHQF
• error handling error propagation workflow errors nested function calls preserve message and stack trace
• error handling error propagation workflow errors cross-file imports preserve message and stack trace
• error handling error propagation step errors basic step error preserves message and stack trace
• error handling error propagation step errors cross-file step error preserves message and function names in stack
• error handling retry behavior regular Error retries until success
• error handling retry behavior FatalError fails immediately without retries
• error handling retry behavior RetryableError respects custom retryAfter delay
• error handling retry behavior maxRetries=0 disables retries
• error handling catchability FatalError can be caught and detected with FatalError.is()
• error handling not registered WorkflowNotRegisteredError fails the run when workflow does not exist
• error handling not registered StepNotRegisteredError fails the step but workflow can catch it
• error handling not registered StepNotRegisteredError fails the run when not caught in workflow
• hookCleanupTestWorkflow - hook token reuse after workflow completion | wrun_01KPCCD3WWDHM6CW911ECYACVZ
• concurrent hook token conflict - two workflows cannot use the same hook token simultaneously | wrun_01KPCCDPWYYK7SDDVZAS5RTVZR
• hookDisposeTestWorkflow - hook token reuse after explicit disposal while workflow still running | wrun_01KPCCEA34XW3234VWKAGGBY86
• stepFunctionPassingWorkflow - step function references can be passed as arguments (without closure vars) | wrun_01KPCCEXC50HDM088D6D25J9XS
• stepFunctionWithClosureWorkflow - step function with closure variables passed as argument | wrun_01KPCCF4PWM5M0H0EEE9HA9TNR
• closureVariableWorkflow - nested step functions with closure variables | wrun_01KPCCFASD8MV7SAMB8DSDQDMK
• spawnWorkflowFromStepWorkflow - spawning a child workflow using start() inside a step | wrun_01KPCCFCMPXG3JJCVSG829RFE8
• health check (queue-based) - workflow and step endpoints respond to health check messages
• pathsAliasWorkflow - TypeScript path aliases resolve correctly | wrun_01KPCCFSR07MX1MSJ7SA9SRX6J
• Calculator.calculate - static workflow method using static step methods from another class | wrun_01KPCCFYDY37GGSGA9RNR4QDHP
• AllInOneService.processNumber - static workflow method using sibling static step methods | wrun_01KPCCG44ADFMRH7V58DWBA0KQ
• ChainableService.processWithThis - static step methods using this to reference the class | wrun_01KPCCG9VNF0E9C4RMMVJWES93
• thisSerializationWorkflow - step function invoked with .call() and .apply() | wrun_01KPCCGFV305H89R2BCCCDDPP3
• customSerializationWorkflow - custom class serialization with WORKFLOW_SERIALIZE/WORKFLOW_DESERIALIZE | wrun_01KPCCGNGYHMPQ7VRV56BN6PBZ
• instanceMethodStepWorkflow - instance methods with "use step" directive | wrun_01KPCCGV94KV173QB4ZJKGWNZ9
• crossContextSerdeWorkflow - classes defined in step code are deserializable in workflow context | wrun_01KPCCH4V3C7AJR7KHFAPDP1X5
• stepFunctionAsStartArgWorkflow - step function reference passed as start() argument | wrun_01KPCCHCW589C3D2V8DXPJ8676
• cancelRun - cancelling a running workflow | wrun_01KPCCHKPEVYDBQ1JNJETP8E02
• cancelRun via CLI - cancelling a running workflow | wrun_01KPCCHW778ZJTDPMM8SV34EM0
• pages router addTenWorkflow via pages router
• pages router promiseAllWorkflow via pages router
• pages router sleepingWorkflow via pages router
• hookWithSleepWorkflow - hook payloads delivered correctly with concurrent sleep | wrun_01KPCCJ753XTKX3R7QJK72A74X
• sleepInLoopWorkflow - sleep inside loop with steps actually delays each iteration | wrun_01KPCCJTT3WZXP5RJ0SXMMV990
• sleepWithSequentialStepsWorkflow - sequential steps work with concurrent sleep (control) | wrun_01KPCCK63F7DKJ698HMKVK8JY4
• importMetaUrlWorkflow - import.meta.url is available in step bundles | wrun_01KPCCKBZ60WYDAEYMPTA1X2AB
• metadataFromHelperWorkflow - getWorkflowMetadata/getStepMetadata work from module-level helper (#1577) | wrun_01KPCCKDTEAC054S5F41V445R4
• resilient start: addTenWorkflow completes when run_created returns 500 | wrun_01KPCCKFNAX2G2S1C0NYHRNBBY

Details by Category

✅ ▲ Vercel Production

App	Passed	Failed	Skipped
✅ astro	81	0	7
✅ example	81	0	7
✅ express	81	0	7
✅ fastify	81	0	7
✅ hono	81	0	7
✅ nextjs-turbopack	86	0	2
✅ nextjs-webpack	86	0	2
✅ nitro	81	0	7
✅ nuxt	81	0	7
✅ sveltekit	81	0	7
✅ vite	81	0	7

✅ 💻 Local Development

App	Passed	Failed	Skipped
✅ astro-stable	82	0	6
✅ express-stable	82	0	6
✅ fastify-stable	82	0	6
✅ hono-stable	82	0	6
✅ nextjs-turbopack-canary	69	0	19
✅ nextjs-turbopack-stable	88	0	0
✅ nextjs-webpack-canary	69	0	19
✅ nextjs-webpack-stable	88	0	0
✅ nitro-stable	82	0	6
✅ nuxt-stable	82	0	6
✅ sveltekit-stable	82	0	6
✅ vite-stable	82	0	6

✅ 📦 Local Production

App	Passed	Failed	Skipped
✅ astro-stable	82	0	6
✅ express-stable	82	0	6
✅ fastify-stable	82	0	6
✅ hono-stable	82	0	6
✅ nextjs-turbopack-canary	69	0	19
✅ nextjs-turbopack-stable	88	0	0
✅ nextjs-webpack-canary	69	0	19
✅ nextjs-webpack-stable	88	0	0
✅ nitro-stable	82	0	6
✅ nuxt-stable	82	0	6
✅ sveltekit-stable	82	0	6
✅ vite-stable	82	0	6

✅ 🐘 Local Postgres

App	Passed	Failed	Skipped
✅ astro-stable	82	0	6
✅ express-stable	82	0	6
✅ fastify-stable	82	0	6
✅ hono-stable	82	0	6
✅ nextjs-turbopack-canary	69	0	19
✅ nextjs-turbopack-stable	88	0	0
✅ nextjs-webpack-canary	69	0	19
✅ nextjs-webpack-stable	88	0	0
✅ nitro-stable	82	0	6
✅ nuxt-stable	82	0	6
✅ sveltekit-stable	82	0	6
✅ vite-stable	82	0	6

✅ 🪟 Windows

App	Passed	Failed	Skipped
✅ nextjs-turbopack	88	0	0

❌ 🌍 Community Worlds

App	Passed	Failed	Skipped
✅ mongodb-dev	5	0	0
❌ mongodb	58	11	0
✅ redis-dev	5	0	0
❌ redis	62	7	0
✅ turso-dev	5	0	0
❌ turso	4	65	0

✅ 📋 Other

App	Passed	Failed	Skipped
✅ e2e-local-dev-nest-stable	82	0	6
✅ e2e-local-postgres-nest-stable	82	0	6
✅ e2e-local-prod-nest-stable	82	0	6

---

📋 View full workflow run