Skip to content

Commit bd3b8d1

Browse files
committed
docs(examples): add job retention options
1 parent 046faf1 commit bd3b8d1

File tree

3 files changed

+6
-0
lines changed

3 files changed

+6
-0
lines changed

examples/jobs/metrics_job.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@ interface MetricsJobPayload {
1919
export default class MetricsJob extends Job<MetricsJobPayload> {
2020
static options: JobOptions = {
2121
queue: 'metrics',
22+
removeOnComplete: true,
23+
removeOnFail: { count: 100 },
2224
}
2325

2426
async execute(): Promise<void> {

examples/jobs/send_email_job.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ interface SendEmailPayload {
88
export default class SendEmailJob extends Job<SendEmailPayload> {
99
static options: JobOptions = {
1010
queue: 'email',
11+
removeOnComplete: { age: '7d', count: 1000 },
12+
removeOnFail: { age: '30d' },
1113
}
1214

1315
async execute(): Promise<void> {

examples/jobs/sync_job.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,8 @@ interface SyncJobPayload {
99
export default class SyncJob extends Job<SyncJobPayload> {
1010
static options: JobOptions = {
1111
adapter: 'sync',
12+
removeOnComplete: false,
13+
removeOnFail: false,
1214
}
1315

1416
async execute(): Promise<void> {

0 commit comments

Comments
 (0)