Make serialization functions async with Encryptor interface

[TooTallNate]

Summary

• Adds Encryptor, EncryptionContext, and KeyMaterial interfaces to @workflow/world
• Makes World extend Encryptor (all methods are optional, so existing implementations are unaffected)
• Converts all 8 dehydrate/hydrate functions in serialization.ts to async with new runId and encryptor parameters
• Adds runId and world to WorkflowOrchestratorContext for threading encryption context through the workflow lifecycle
• Updates all callers throughout: runtime, step handler, suspension handler, resume-hook, observability, CLI, web-shared, workbenches, world-testing, and tests

This is a no-op refactor — the encryptor parameter is unused (prefixed with _) in this PR. All callers pass {} as the encryptor. The actual encryption logic will be wired in a subsequent PR.

Stack

• Depends on Generate runId client-side in start() and simplify streaming types #954 (Generate runId client-side in start())

Test plan

All 303 core tests pass. Build succeeds.

[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, Open in v0	Feb 8, 2026 10:13am
example-nextjs-workflow-webpack	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am
example-workflow	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am
workbench-astro-workflow	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am
workbench-express-workflow	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am
workbench-fastify-workflow	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am
workbench-hono-workflow	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am
workbench-nitro-workflow	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am
workbench-nuxt-workflow	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am
workbench-sveltekit-workflow	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am
workbench-vite-workflow	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am
workflow-docs	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am
workflow-nest	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am
workflow-swc-playground	Ready	Preview, Comment, Open in v0	Feb 8, 2026 10:13am

[changeset-bot]

🦋 Changeset detected

Latest commit: 7b2edf6

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

This PR includes changesets to release 19 packages

Name	Type
@workflow/core	Patch
@workflow/world	Patch
@workflow/cli	Patch
@workflow/web	Patch
@workflow/world-testing	Patch
@workflow/builders	Patch
@workflow/next	Patch
@workflow/nitro	Patch
@workflow/web-shared	Patch
workflow	Patch
@workflow/world-local	Patch
@workflow/world-postgres	Patch
@workflow/world-vercel	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

[github-actions]

🧪 E2E Test Results

❌ Some tests failed

Summary

	Passed	Failed	Skipped	Total
✅ ▲ Vercel Production	490	0	38	528
✅ 💻 Local Development	418	0	62	480
✅ 📦 Local Production	418	0	62	480
✅ 🐘 Local Postgres	418	0	62	480
✅ 🪟 Windows	45	0	3	48
❌ 🌍 Community Worlds	29	163	12	204
✅ 📋 Other	123	0	21	144
Total	1941	163	260	2364

❌ Failed Tests

🌍 Community Worlds (163 failed)

mongodb (40 failed):

• addTenWorkflow
• addTenWorkflow
• should work with react rendering in step
• promiseAllWorkflow
• promiseRaceWorkflow
• promiseAnyWorkflow
• hookWorkflow
• webhookWorkflow
• sleepingWorkflow
• nullByteWorkflow
• workflowAndStepMetadataWorkflow
• fetchWorkflow
• promiseRaceStressTestWorkflow
• 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()
• hookCleanupTestWorkflow - hook token reuse after workflow completion
• concurrent hook token conflict - two workflows cannot use the same hook token simultaneously
• stepFunctionPassingWorkflow - step function references can be passed as arguments (without closure vars)
• stepFunctionWithClosureWorkflow - step function with closure variables passed as argument
• closureVariableWorkflow - nested step functions with closure variables
• spawnWorkflowFromStepWorkflow - spawning a child workflow using start() inside a step
• pathsAliasWorkflow - TypeScript path aliases resolve correctly
• Calculator.calculate - static workflow method using static step methods from another class
• AllInOneService.processNumber - static workflow method using sibling static step methods
• ChainableService.processWithThis - static step methods using this to reference the class
• thisSerializationWorkflow - step function invoked with .call() and .apply()
• customSerializationWorkflow - custom class serialization with WORKFLOW_SERIALIZE/WORKFLOW_DESERIALIZE
• instanceMethodStepWorkflow - instance methods with "use step" directive
• crossContextSerdeWorkflow - classes defined in step code are deserializable in workflow context
• stepFunctionAsStartArgWorkflow - step function reference passed as start() argument
• pages router addTenWorkflow via pages router
• pages router promiseAllWorkflow via pages router
• pages router sleepingWorkflow via pages router

redis (40 failed):

• addTenWorkflow
• addTenWorkflow
• should work with react rendering in step
• promiseAllWorkflow
• promiseRaceWorkflow
• promiseAnyWorkflow
• hookWorkflow
• webhookWorkflow
• sleepingWorkflow
• nullByteWorkflow
• workflowAndStepMetadataWorkflow
• fetchWorkflow
• promiseRaceStressTestWorkflow
• 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()
• hookCleanupTestWorkflow - hook token reuse after workflow completion
• concurrent hook token conflict - two workflows cannot use the same hook token simultaneously
• stepFunctionPassingWorkflow - step function references can be passed as arguments (without closure vars)
• stepFunctionWithClosureWorkflow - step function with closure variables passed as argument
• closureVariableWorkflow - nested step functions with closure variables
• spawnWorkflowFromStepWorkflow - spawning a child workflow using start() inside a step
• pathsAliasWorkflow - TypeScript path aliases resolve correctly
• Calculator.calculate - static workflow method using static step methods from another class
• AllInOneService.processNumber - static workflow method using sibling static step methods
• ChainableService.processWithThis - static step methods using this to reference the class
• thisSerializationWorkflow - step function invoked with .call() and .apply()
• customSerializationWorkflow - custom class serialization with WORKFLOW_SERIALIZE/WORKFLOW_DESERIALIZE
• instanceMethodStepWorkflow - instance methods with "use step" directive
• crossContextSerdeWorkflow - classes defined in step code are deserializable in workflow context
• stepFunctionAsStartArgWorkflow - step function reference passed as start() argument
• pages router addTenWorkflow via pages router
• pages router promiseAllWorkflow via pages router
• pages router sleepingWorkflow via pages router

starter (42 failed):

• addTenWorkflow
• addTenWorkflow
• should work with react rendering in step
• promiseAllWorkflow
• promiseRaceWorkflow
• promiseAnyWorkflow
• hookWorkflow
• webhookWorkflow
• sleepingWorkflow
• nullByteWorkflow
• workflowAndStepMetadataWorkflow
• fetchWorkflow
• promiseRaceStressTestWorkflow
• 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()
• hookCleanupTestWorkflow - hook token reuse after workflow completion
• concurrent hook token conflict - two workflows cannot use the same hook token simultaneously
• stepFunctionPassingWorkflow - step function references can be passed as arguments (without closure vars)
• stepFunctionWithClosureWorkflow - step function with closure variables passed as argument
• closureVariableWorkflow - nested step functions with closure variables
• spawnWorkflowFromStepWorkflow - spawning a child workflow using start() inside a step
• health check (queue-based) - workflow and step endpoints respond to health check messages
• health check (CLI) - workflow health command reports healthy endpoints
• pathsAliasWorkflow - TypeScript path aliases resolve correctly
• Calculator.calculate - static workflow method using static step methods from another class
• AllInOneService.processNumber - static workflow method using sibling static step methods
• ChainableService.processWithThis - static step methods using this to reference the class
• thisSerializationWorkflow - step function invoked with .call() and .apply()
• customSerializationWorkflow - custom class serialization with WORKFLOW_SERIALIZE/WORKFLOW_DESERIALIZE
• instanceMethodStepWorkflow - instance methods with "use step" directive
• crossContextSerdeWorkflow - classes defined in step code are deserializable in workflow context
• stepFunctionAsStartArgWorkflow - step function reference passed as start() argument
• pages router addTenWorkflow via pages router
• pages router promiseAllWorkflow via pages router
• pages router sleepingWorkflow via pages router

turso (41 failed):

• addTenWorkflow
• addTenWorkflow
• should work with react rendering in step
• promiseAllWorkflow
• promiseRaceWorkflow
• promiseAnyWorkflow
• hookWorkflow
• webhookWorkflow
• sleepingWorkflow
• nullByteWorkflow
• workflowAndStepMetadataWorkflow
• fetchWorkflow
• promiseRaceStressTestWorkflow
• 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()
• hookCleanupTestWorkflow - hook token reuse after workflow completion
• concurrent hook token conflict - two workflows cannot use the same hook token simultaneously
• stepFunctionPassingWorkflow - step function references can be passed as arguments (without closure vars)
• stepFunctionWithClosureWorkflow - step function with closure variables passed as argument
• closureVariableWorkflow - nested step functions with closure variables
• spawnWorkflowFromStepWorkflow - spawning a child workflow using start() inside a step
• health check (queue-based) - workflow and step endpoints respond to health check messages
• pathsAliasWorkflow - TypeScript path aliases resolve correctly
• Calculator.calculate - static workflow method using static step methods from another class
• AllInOneService.processNumber - static workflow method using sibling static step methods
• ChainableService.processWithThis - static step methods using this to reference the class
• thisSerializationWorkflow - step function invoked with .call() and .apply()
• customSerializationWorkflow - custom class serialization with WORKFLOW_SERIALIZE/WORKFLOW_DESERIALIZE
• instanceMethodStepWorkflow - instance methods with "use step" directive
• crossContextSerdeWorkflow - classes defined in step code are deserializable in workflow context
• stepFunctionAsStartArgWorkflow - step function reference passed as start() argument
• pages router addTenWorkflow via pages router
• pages router promiseAllWorkflow via pages router
• pages router sleepingWorkflow via pages router

Details by Category

✅ ▲ Vercel Production

App	Passed	Failed	Skipped
✅ astro	44	0	4
✅ example	44	0	4
✅ express	44	0	4
✅ fastify	44	0	4
✅ hono	44	0	4
✅ nextjs-turbopack	47	0	1
✅ nextjs-webpack	47	0	1
✅ nitro	44	0	4
✅ nuxt	44	0	4
✅ sveltekit	44	0	4
✅ vite	44	0	4

✅ 💻 Local Development

App	Passed	Failed	Skipped
✅ astro-stable	41	0	7
✅ express-stable	41	0	7
✅ fastify-stable	41	0	7
✅ hono-stable	41	0	7
✅ nextjs-turbopack-stable	45	0	3
✅ nextjs-webpack-stable	45	0	3
✅ nitro-stable	41	0	7
✅ nuxt-stable	41	0	7
✅ sveltekit-stable	41	0	7
✅ vite-stable	41	0	7

✅ 📦 Local Production

App	Passed	Failed	Skipped
✅ astro-stable	41	0	7
✅ express-stable	41	0	7
✅ fastify-stable	41	0	7
✅ hono-stable	41	0	7
✅ nextjs-turbopack-stable	45	0	3
✅ nextjs-webpack-stable	45	0	3
✅ nitro-stable	41	0	7
✅ nuxt-stable	41	0	7
✅ sveltekit-stable	41	0	7
✅ vite-stable	41	0	7

✅ 🐘 Local Postgres

App	Passed	Failed	Skipped
✅ astro-stable	41	0	7
✅ express-stable	41	0	7
✅ fastify-stable	41	0	7
✅ hono-stable	41	0	7
✅ nextjs-turbopack-stable	45	0	3
✅ nextjs-webpack-stable	45	0	3
✅ nitro-stable	41	0	7
✅ nuxt-stable	41	0	7
✅ sveltekit-stable	41	0	7
✅ vite-stable	41	0	7

✅ 🪟 Windows

App	Passed	Failed	Skipped
✅ nextjs-turbopack	45	0	3

❌ 🌍 Community Worlds

App	Passed	Failed	Skipped
✅ mongodb-dev	3	0	0
❌ mongodb	5	40	3
✅ redis-dev	3	0	0
❌ redis	5	40	3
✅ starter-dev	3	0	0
❌ starter	3	42	3
✅ turso-dev	3	0	0
❌ turso	4	41	3

✅ 📋 Other

App	Passed	Failed	Skipped
✅ e2e-local-dev-nest-stable	41	0	7
✅ e2e-local-postgres-nest-stable	41	0	7
✅ e2e-local-prod-nest-stable	41	0	7

---

📋 View full workflow run

[Copilot]

Pull request overview

This PR adds encryption support infrastructure to the Workflow SDK as a no-op refactor, preparing for future E2E encryption implementation. It introduces Encryptor, EncryptionContext, and KeyMaterial interfaces to @workflow/world, extends the World interface to include optional encryption methods, and converts all 8 serialization functions (dehydrate/hydrate) to async with new runId and encryptor parameters.

Changes:

• Added encryption interfaces (Encryptor, EncryptionContext, KeyMaterial) to @workflow/world package
• Made all 8 serialization functions async and added runId and encryptor parameters (unused in this PR, prefixed with _)
• Updated WorkflowOrchestratorContext to include runId and world for threading encryption context through workflow lifecycle
• Updated all 200+ call sites across runtime, step handlers, hook handlers, CLI, web-shared, workbenches, and tests to await async hydration and pass new parameters

Reviewed changes

Copilot reviewed 42 out of 42 changed files in this pull request and generated no comments.

Show a summary per file

File	Description
packages/world/src/interfaces.ts	Added Encryptor, EncryptionContext, KeyMaterial interfaces; extended World to include Encryptor
packages/core/src/serialization.ts	Converted all 8 dehydrate/hydrate functions to async with new runId and encryptor parameters
packages/core/src/serialization.test.ts	Added test wrapper functions to maintain backward-compatible signatures for existing tests
packages/core/src/workflow.ts	Updated runWorkflow to accept world parameter and pass it through orchestrator context
packages/core/src/private.ts	Added runId and world to WorkflowOrchestratorContext interface
packages/core/src/workflow/hook.ts	Updated to use async hydration with .then()/.catch() pattern in event consumer
packages/core/src/step.ts	Updated to use async hydration with .then()/.catch() pattern in event consumer
packages/core/src/runtime/*.ts	Updated start, run, step-handler, suspension-handler, resume-hook to await async serialization
packages/core/src/observability.ts	Converted all hydration helper functions to async and properly await them
packages/cli/src/lib/inspect/output.ts	Updated all hydration calls to properly await and pass world
packages/web-shared/src/api/workflow-server-actions.ts	Converted hydrate helper to async and updated all callers to await
workbench//api/trigger	All 15 workbench trigger endpoints updated to await hydration and pass empty runId/encryptor
packages/core/e2e/e2e.test.ts	Removed withResolvers import and updated dehydrateWorkflowArguments call (missing cleanup on lines 96-97)
packages/core/e2e/bench.bench.ts	Properly removed all references to ops variable

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[TooTallNate]

• Make serialization functions async with Encryptor interface #955 👈 (View in Graphite)
• Generate runId client-side in start() and simplify streaming types #954
• main

This stack of pull requests is managed by Graphite. Learn more about stacking.