# Background Job Architecture {#background-job-architecture}


Worker processes, job queues, and scheduled tasks.


## Overview {#overview}


Gauzy uses BullMQ (Redis-backed) for background job processing:





```mermaid
graph LR
    API[API Server] -->|Enqueue| Redis[(Redis Queue)]
    Redis --> Worker1[Worker 1]
    Redis --> Worker2[Worker 2]
    Worker1 -->|Result| DB[(Database)]
    Worker2 -->|Result| DB
```






## Job Types {#job-types}


| Queue         | Jobs                           |
| ------------- | ------------------------------ |
| `email`       | Send emails, notifications     |
| `integration` | Sync with third-party services |
| `screenshot`  | Process screenshots            |
| `export`      | Export data to CSV/Excel       |
| `import`      | Import data from files         |
| `cleanup`     | Archive/delete old data        |


## Creating a Job {#creating-a-job}


```typescript
@Injectable()
export class EmailService {
  constructor(@InjectQueue("email") private emailQueue: Queue) {}

  async sendWelcomeEmail(userId: string) {
    await this.emailQueue.add(
      "welcome",
      {
        userId,
        template: "welcome",
      },
      {
        attempts: 3,
        backoff: { type: "exponential", delay: 5000 },
      },
    );
  }
}
```


## Processing a Job {#processing-a-job}


```typescript
@Processor("email")
export class EmailProcessor {
  @Process("welcome")
  async handleWelcome(job: Job) {
    const { userId, template } = job.data;
    await this.mailerService.send(userId, template);
  }
}
```


## Scheduled Tasks {#scheduled-tasks}


```typescript
@Injectable()
export class CleanupService {
  @Cron("0 0 * * *") // Daily at midnight
  async cleanOldLogs() {
    await this.activityLogService.deleteOlderThan(90);
  }
}
```


## Monitoring {#monitoring}


Use Bull Dashboard for queue monitoring:

```
GET /admin/queues
```


## Related Pages {#related-pages}


- [Worker Architecture](https://sourcey-gauzy.pages.dev/architecture/worker-architecture/index.md) — worker process
- [Redis & Caching](https://sourcey-gauzy.pages.dev/advanced/redis-and-caching/index.md) — Redis infrastructure
- [Scaling & HA](https://sourcey-gauzy.pages.dev/devops/scaling/index.md) — scaling workers