dataqueue-advanced

What problem does it solve?

Orchestrate advanced DataQueue workflows with dependencies, memoization, waits, and cron, ensuring reliable, lossless processing across distributed workers.

Core Features & Use Cases

• Job dependencies with dependsOn to ensure prerequisites complete before continuation.
• Step memoization using ctx.run to cache results and replay on re-invocation.
• Time-based and token-based waits (waitFor, waitUntil, token waits) to coordinate human and system actions.
• Cron scheduling and idempotent handling for recurring, fault-tolerant jobs.

Quick Start

Define a handler that uses ctx.run for memoization and ctx.waitFor for timing, then enqueue jobs with dependsOn, tags, cron, and idempotency settings to see advanced patterns in action.