Run a distributed priority job queue with Redis and Anthropic

by Oneclick AI Squad ✓ · 1 views · created 2026-10-01 · Engineering, AI Summarization

What this workflow does

This workflow has 84 nodes and runs when an HTTP POST request hits its webhook URL (plus 5 other triggers). Along the way it connects Redis.

How it runs

Trigger: When an HTTP POST request hits its webhook URL (plus 5 other triggers).

1. Set Producer Config (Edit Fields (Set)): sets 4 fields: defaultMaxAttempts, retentionSeconds, notifyChannel…
2. Parse Queue Status Request (Code): runs custom JavaScript code
3. Parse Cancellation Request (Code): runs custom JavaScript code
4. Set Worker Configuration (Edit Fields (Set)): sets 11 fields: laneOrder, agingEvery, maxJobsPerRun…
5. Maintenance Configuration (Edit Fields (Set)): sets 3 fields: batchSize, retentionSeconds, notifyChannel
6. Validate Job Configuration (Code): runs custom JavaScript code
7. Check Job Id Presence (If): checks a condition and branches into true / false
8. Check Valid Cancel Request (If): checks a condition and branches into true / false
9. Redis: incr
10. Plan Maintenance (Code): runs custom JavaScript code

…plus 68 more steps. See the full node list below.

Services it uses

Redis

Before you upgrade to n8n 3.0

Nodes used (10)

• Webhookn8n-nodes-base.webhook
• Edit Fields (Set)n8n-nodes-base.set
• Coden8n-nodes-base.code
• Ifn8n-nodes-base.if
• Respond to Webhookn8n-nodes-base.respondToWebhook
• Redisn8n-nodes-base.redis
• Redis Triggern8n-nodes-base.redisTrigger
• Schedule Triggern8n-nodes-base.scheduleTrigger
• Switchn8n-nodes-base.switch
• HTTP Requestn8n-nodes-base.httpRequest

From the author

Quick overview This workflow implements a distributed priority job queue in n8n using Redis for storage, lane-based scheduling, and worker wakeups, with optional Anthropic LLM execution and outbound HTTPS calls, plus webhook endpoints for enqueueing jobs,…

View the original on n8n.io → Check your own copy