Upstash Workflow JS
UpstashOfficialCreated by Upstash
- Skill
- Tool integration
- Cloud and DevOps
- MIT
- Medium risk
AutoGineer summary
Written by AutoGineer from the skill’s own files, not by the author
The Upstash Workflow SDK enables developers to create reliable, multi-step workflows within serverless environments. By leveraging QStash, it allows functions to survive timeouts, retries, and restarts, effectively managing long-running processes that span minutes or days without keeping the underlying function execution active. It supports complex orchestration patterns, including step-by-step execution, external API calls, event waiting, human-in-the-loop approvals, and sophisticated flow control.
What it does
- Exposes serverless endpoints for durable workflow execution.
- Manages multi-step processes that persist across function restarts and timeouts.
- Provides tools for flow control, including concurrency, rate limiting, and parallelism.
- Supports advanced patterns like cross-workflow invocation and waiting for external events.
- Enables local development and testing via the QStash dev server.
- Facilitates human-in-the-loop workflows and real-time updates.
When to use it
- When building long-running tasks that exceed standard serverless function execution limits.
- When implementing saga or orchestration patterns in a distributed system.
- When you need reliable background jobs with built-in checkpointing and retries.
- When building AI agents or orchestrators that require stateful, multi-step execution.
- When integrating human approval steps into automated backend processes.
Advantages
- Eliminates the need to hold serverless functions open for long durations.
- Built-in support for retries, failure callbacks, and dead-letter queues.
- Seamless integration with popular serverless platforms like Vercel and Cloudflare Workers.
- Simplifies complex state management for asynchronous operations.
Usage examples
- “How do I define a basic two-step workflow using the Upstash SDK?”
- The agent provides a code snippet using the serve() function and context.run() to define sequential steps that persist across execution.
- “How can I trigger a workflow from my existing backend code?”
- The agent demonstrates initializing the Workflow Client with a QStash token and using the trigger() method to initiate the workflow URL.
Install
Download the skill as a ZIP:
https://mp-staging.autogineer.com/agent-skills/upstash/upstash-workflow-js/downloadUnzip it into the cross-client skills folder of your project:
mkdir -p .agents/skills && unzip upstash-workflow-js.zip -d .agents/skills
Documentation by Upstash
Upstash Workflow SDK
Bundled docs and source
Before writing or debugging SDK code, check node_modules/@upstash/workflow/docs/ for bundled docs and node_modules/@upstash/workflow/src/ for readable TypeScript source. Read and search the relevant files when present; otherwise use the references in this skill.
Quick Start
The Upstash Workflow SDK lets you expose serverless workflow endpoints and run them reliably using QStash under the hood.
Install:
npm install @upstash/workflowDefine a simple workflow endpoint:
import { serve } from "@upstash/workflow";
export const { POST } = serve(async (context) => {
await context.run("step-1", () => console.log("step 1"));
await context.run("step-2", () => console.log("step 2"));
});Trigger it from your backend:
import { Client } from "@upstash/workflow";
const client = new Client({ token: process.env.QSTASH_TOKEN! });
await client.trigger({ url: "https://your-app.com/api/workflow" });Other Skill Files
These files contain the full documentation. Use them for details, patterns, and advanced behavior.
basics:
basics/serve – How to expose workflow endpoints.
basics/context – Full API for workflow
context(steps, waits, webhooks, events, invoke, etc.).basics/client – Using the Workflow client to trigger, cancel, inspect, and notify runs.
features:
features/invoke – Cross‑workflow invocation.
features/reliability – Retries, failure callbacks, and DLQ.
features/flow-control – Rate limits, concurrency, and parallelism.
features/wait-for-event – Notify and wait-for-event patterns.
features/webhooks – Webhook creation and consumption.
how to:
how-to/local-dev – Local QStash dev server (auto via
QSTASH_DEV=true) and tunneling.how-to/realtime – Realtime and human‑in‑the‑loop workflows.
how-to/migrations – Migrating workflows safely.
how-to/middleware – Adding middleware to workflows.
other files:
rest-api – Low-level REST endpoints for interacting with QStash/Workflow.
troubleshooting – Common debugging and environment issues.
agents – Using Workflow with agents, orchestrators, and automation patterns.
Files
- ATTRIBUTION.mdAdded by AutoGineer892 B
- LICENSELicence file added by AutoGineer1.1 KiB
- SKILL.md3.4 KiB
- agents.md6.7 KiB
- basics/client.md4.1 KiB
- basics/context.md5.1 KiB
- basics/serve.md2.4 KiB
- features/flow-control.md3.9 KiB
- features/invoke.md2.6 KiB
- features/retries-failures-reliability.md6.3 KiB
- features/wait-for-event.md2.8 KiB
- features/webhooks.md2.5 KiB
- how-to/local-dev.md5.0 KiB
- how-to/middleware.md4.7 KiB
- how-to/migrations.md4.8 KiB
- how-to/realtime.md4.8 KiB
- rest-api.md6.6 KiB
- troubleshooting.md4.8 KiB
troubleshooting.md
Workflow Troubleshooting (TypeScript)
This guide provides clear, TypeScript‑focused patterns for diagnosing and fixing common issues in Upstash Workflow. It highlights correct usage of core workflow features and shows how to avoid pitfalls that commonly occur in real applications.
Steps Inside try/catch
Workflow steps (context.run, context.sleep, context.sleepUntil, context.call) intentionally throw WorkflowAbort after completing. Catching this error prevents the workflow engine from progressing.
Correct pattern: rethrow WorkflowAbort or avoid try/catch around steps.
import { WorkflowAbort } from "@upstash/workflow";
try {
// Any step will throw WorkflowAbort
const result = await context.run("step", () => "ok");
} catch (err) {
if (err instanceof WorkflowAbort) throw err; // required
// handle real errors
}If you must handle errors, move the try/catch into the function passed to context.run.
requestPayload Becoming Undefined
During context.call, the workflow endpoint is invoked multiple times internally. Before the first step executes, context.requestPayload may appear undefined.
Fix: capture the payload via a step:
export const { POST } = serve(async (context) => {
const payload = await context.run("get-payload", () => context.requestPayload);
// payload remains stable even during context.call
await context.call("my-call", {
url: "https://example.com",
body: payload,
});
});Header considerations: When triggering workflows, ensure payload‑friendly headers like:
Content-Type: text/plainContent-Type: application/json
Signature Verification Failures
If QStash request verification fails:
Ensure the workflow is triggered through QStash (
client.triggeror publish)Verify
QSTASH_CURRENT_SIGNING_KEYandQSTASH_NEXT_SIGNING_KEYPass appropriate
Content-Typeheaders when triggering
Error looks like:
Failed to verify that the Workflow request comes from QStash: ...Authorization Errors from Early Returns
If your workflow returns before running any step, the SDK interprets this as failed authorization:
HTTP 400 – Failed to authenticate Workflow request.To safely perform non‑deterministic checks, wrap them in a step:
export const { POST } = serve(async (context) => {
const shouldExit = await context.run("check-condition", () => Math.random() > 0.5);
if (shouldExit) return;
// remaining workflow
});Retry Configuration
Retries come from two locations:
Workflow start (
client.trigger): default 3, applies to workflow stepscontext.call: default 0context.invoke: default 0
Use these in combination to tune behavior correctly.
Verbose Mode Diagnostics
Enable verbose logging to debug rare edge cases:
serve(handler, { verbose: true });Useful warnings include:
Localhost in workflow URL
Duplicate step execution
Network response anomalies
Parallel
context.callrace warnings
Each of these indicates environmental or routing issues rather than workflow logic problems.
HTTPS Protocol Issues (Proxy Environments)
If deployed behind a proxy that downgrades HTTPS → HTTP (e.g., Railway), the SDK may infer the wrong protocol.
Fix: explicitly set:
UPSTASH_WORKFLOW_URL=https://your-deployment-urlWorkflow Stuck on First Step
If the first step appears stuck:
Check step logs in the dashboard
Ensure the endpoint URL is correct and reachable
Verify SDK versions
If inference is failing, explicitly set
baseUrl:
serve(handler, { baseUrl: "https://your-url" });Non‑workflow Destination Error
Occurs when triggering a non‑workflow endpoint or using mismatched SDK versions.
detected a non-workflow destination for trigger/invokeEnsure:
The URL points to a
serve()workflow endpointBoth caller and workflow endpoint use the latest SDK
Vercel Preview Deployment Protection
Preview deployments block external requests unless bypassed.
Steps:
Create a bypass secret in Vercel → Deployment Protection
Add it to the QStash client + pass it when triggering
import { Client as QStash } from "@upstash/qstash";
import { serve } from "@upstash/workflow/nextjs";
export const { POST } = serve(
async (context) => {
// workflow logic
},
{
qstashClient: new QStash({
token: process.env.QSTASH_TOKEN!,
headers: {
"x-vercel-protection-bypass": process.env.VERCEL_AUTOMATION_BYPASS_SECRET!,
},
}),
}
);
// Triggering
await client.trigger({
url: "https://preview.vercel.app/workflow",
headers: {
"x-vercel-protection-bypass": process.env.VERCEL_AUTOMATION_BYPASS_SECRET!,
},
body: "hello",
});Both trigger header and client header are required.
Requirements and compatibility
Works with: Claude Code, Claude apps, OpenAI Codex, GitHub Copilot, Cursor, Gemini CLI, Kiro, OpenCode, Goose, Amp, Roo Code, JetBrains Junie, Factory Droid, Devin (ex-Windsurf), Mistral Vibe, OpenHands, Letta
“Works with” means the tool reads the open Agent Skills format; a skill written for one tool may use features others lack.
Needs: Needs Node.js
Security
What our scanner noticed· Medium risk
- Possible data-exfiltration endpoints
A static scan is not a guarantee. Skills are third-party content: review a skill before you let an agent use it.
Attribution and licence
- Created by
- Upstash
- Publisher
- Upstash (Official)
- Source
- upstash/skills · skills/upstash-workflow-js · commit 9f9e3e5
- Licence
- MIT License (redistribution allowed)
- LICENSE (added by AutoGineer from LICENSE)
- ATTRIBUTION.md (written by AutoGineer)
- Synced
AutoGineer is not affiliated with or endorsed by Upstash.
Download ZIP
The ZIP holds the skill’s files, its licence files and an ATTRIBUTION.md. Download upstash-workflow-js.zip