Tasks examples

Both examples import the adapter from its public package root and exercise the server through app.handle(new Request(...)). Build the root package, install the example, and run its smoke test:

bun run examples:setup
bun run build
bun run --cwd examples/tasks smoke

The providers persist pending MRTR requests, partial responses, and lifetime-unique keys, but do not replay work after input. Safe continuation requires an application-defined checkpoint that consumes those responses; replaying the original executor can duplicate side effects.

Subprocess provider

The subprocess example stores task descriptors and snapshots in SQLite before spawning a fixed Bun worker command. The child opens the same database, reconstructs the synchronous Elysia worker application, and reports terminal state. Tests prove the work ran in another PID, remains pollable after reopening the provider, and observes cancellation without interpolating model input into a shell command.

const child = Bun.spawn([process.execPath, workerPath, databasePath, taskId], {
  stdout: 'ignore',
  stderr: 'inherit'
})

BullMQ provider

The BullMQ example uses a Queue, Worker, Redis task records, and pub/sub snapshots. ioredis-mock keeps the demo self-contained and validates the queue boundary, but it is not a production Redis substitute.

Production deployments should use a real Redis service with separate worker connections, maxRetriesPerRequest: null for workers, a noeviction policy, and no ioredis keyPrefix. Keep queue payloads limited to the durable descriptor and deployment-controlled identity.