Task Scheduling & Jobs
Priority: P1 (OPERATIONAL)
Workflow: Add Scheduled Task
- Register ScheduleModule — Import
ScheduleModule.forRoot() in AppModule.
- Create cron handler — Decorate service method with
@Cron(CronExpression.*).
- Add distributed lock — Apply Redis lock decorator to prevent multi-pod duplication.
- Offload heavy work — Push job IDs to BullMQ; let workers process them.
- Wrap in try/catch — Uncaught exceptions in cron handlers crash entire Node process.
- Verify — Test with 2+ instances to confirm only one acquires lock.
Problem & Solution
- Problem:
@Cron() runs on every instance. In K8s with 3 pods, your "Daily Report" runs 3 times.
- Solution: Distributed Locking using Redis.
- Pattern: Using decorator to wrap cron method.
- Logic:
SET resource_name my_random_value NX PX 30000 (Redis Atomic Set).
Cron Decorator Pattern
See implementation examples
- Tools: Use
nestjs-redlock or custom Redis wrapper via redlock library.
Cron-to-Queue Offload
See implementation examples
Job Robustness
- Isolation: Never perform heavy processing inside Cron handler.
- Pattern: Cron -> Push Job ID to Queue (BullMQ) -> Worker processes it.
- Why: Cron schedulers can get blocked by Event Loop; Workers scalable.
- Error Handling: Wrap ALL cron logic in
try/catch. Uncaught exceptions in Cron job can crash entire Node process.
Anti-Patterns
- No unguarded cron logic: Always wrap in
try/catch; uncaught exceptions crash entire Node process.
- No direct cron processing: Push to BullMQ queue; workers scalable, cron handlers not.
- No bare @Cron in multi-pod: Use distributed locking (redlock) to prevent duplicate concurrent runs.