prune method

  1. @override
Future<int> prune({
  1. Duration? olderThan,
})
override

Prune old failed jobs

Implementation

@override
Future<int> prune({Duration? olderThan}) async {
  final cutoff =
      DateTime.now().subtract(olderThan ?? const Duration(days: 7));
  final oldJobs = await _dlq.getByDateRange(
    DateTime.fromMillisecondsSinceEpoch(0),
    cutoff,
  );

  for (final job in oldJobs) {
    await _dlq.remove(job.id);
  }

  return oldJobs.length;
}